List of all items
Macros
- acknowledgement_batches
- assignment_dirs_fixture
- async_write_delegate
- authorization_refusal
- bench_failures
- bench_main
- benchmark_latency_fixture
- benchmark_scenario_fixture
- bind_retry_fixture
- bootstrap_parser_fixture
- bound_start_fixture
- bounded_bfs
- bounded_unit_modules
- break_glass_golden_id
- broker_config
- broker_test_setup
- capture_layer_fixture
- cli_main
- compacted_batch
- compaction_record_fixture
- compression_bytes_fixture
- config_alter_handler
- connect_cli_client
- connection_policy
- consumer_fetch_fixture
- control_marker_fixture
- controller_request
- create_topic_fixture
- decoded_dispatch
- delete_topic_request
- described_group_rows
- directory_tree_fixture
- dispatch_capacity_parser
- dispatch_table
- duration_cases_fixture
- duration_parser_fixture
- empty_endpoint_voters
- empty_match_acl_filter
- ephemeral_port_fixture
- epoch_checkpoint_failure
- epoch_log_view
- epoch_millis_fn
- epoch_record_batch_fixture
- evicted_local_segments
- export_segment_data_fixture
- file_region_fixture
- finalized_feature_fixture
- fixture_constructors
- flag_metadata_fixture
- format_directories_fixture
- forwardable_requests
- frame_max_parser
- frame_prefix_fixture
- freeze_refusal_rules
- guard_response
- heartbeat_status
- hydrate_member_epochs
- index_floor_lookup
- index_seed_helpers
- java_string_producer_source
- jvm_checkpoint_dump_fixture
- jvm_principal_golden
- keyed_record_batch_fixture
- legacy_policy_fixture
- member_identity_fixtures
- member_key_boundaries
- metric_registry_fixture
- minio_fixture
- model_properties
- model_runner
- model_transition
- named_acl_gates
- offset_fetch_rows
- otlp_exporter
- parsed_cli_entrypoint
- partition_gate
- patterned_bytes_fixture
- private_dispatch_table
- producer_batch_fixture
- projection_identity
- quorum_epoch_encoder
- quorum_epoch_requests
- reassignment_fields
- rebuild_reconciliation_group
- reconciliation_actions
- reconciliation_next_state
- record_batch_fixture
- record_header_text
- record_limit_fixture
- record_strings
- records_payload_match
- refused_fetch_partition_fixture
- registration_feature_projection
- remote_metadata_missing
- remote_segment_check
- remote_segment_fixtures
- remote_segment_transition_matrix
- remote_started_segment
- replication_target_guard
- request_frame_fixture
- request_test_identity
- required_topics
- response_errors
- s3_archive_config_fixture
- schedule_commit_changes
- scram_client_first
- scram_client_proof_fixture
- scram_users_fixture
- sendfile_match
- sendfile_platform
- set_runtime
- share_consumption_driver
- share_dlq_meters
- share_first_fetch
- share_fixture_schemas
- share_group_denial
- share_partition_results
- share_refusal_matrix
- share_state_handler
- share_state_request
- share_state_results
- simulation_actions
- simulation_earliest_timer
- simulation_heartbeat
- simulation_step
- simulation_transport
- single_partition_produce_fixture
- single_replica_partition_fixture
- snapshot_member_maps
- snapshot_node_fixture
- snapshot_topic_fixture
- sorted_index_cursor
- splitmix64_step
- string_mutations
- supported_feature_fixture
- supported_features_fixture
- sweep_loop
- tagged_wire
- test_authorizer
- throttle_probes
- timer_hooks
- timestamped_batch
- token_refusal_result
- topic_record_fixture
- unix_millis_fixture
- unthrottled_wire
- validate_archive_rows
- vector_request_fixture
- voter_endpoints
- wal_capture_topic_fixture
- wire_codec_helpers
- wire_codes
- wire_test_driver
- worm_object_set
- worm_segment_fixture
Attribute Macros
- argv_entrypoint
- bootstrap_cli_fields
- config_table
- decode_dispatch
- delegate_authorizer
- extension_wire
- finished_selection
- flexible_value
- flush_group_records
- gcs_fields
- hex_bytes_identity
- human_units
- index_open
- krabka_env
- membership_defaults
- metadata_log_delegate
- missing_remote_reads
- model_type
- object_ops
- object_store_config
- object_store_delegate
- partition_spawn_parameters
- reaper_task
- reconciliation_fields
- remote_operation
- retained_timestamp_bounds
- round_robin_site_lemma
- runtime_policy_fields
- s3_fields
- scalar_id
- sendfile_cfg
- share_produce_parameters
- share_request_identity
- share_state_operation
- test_scalar
- token_dispatch
- topic_filter
- transport_errors
- voter_admission
Derive Macros
- BackgroundControllers
- EnumStr
- FieldDefaults
- FlexibleArrayValue
- FlexibleEpochValue
- GroupLifecycle
- GroupRecordKey
- GroupTimingConfig
- KafkaUuid
- ModelEpochLedger
- NodeEndpoints
- PartitionMessage
- PrimitiveCmp
- ReconciliationAction
- ReconciliationGroup
- ReconciliationMember
- RefinedNewtype
- RegisterMetrics
- ReplayMemberMaps
- RuntimeOverlay
- ScheduledLoads
- ShareStateValue
- SparseIndex
- UnitSchema
- WireStateBatch