List of all items

Structs

• admin::AbortTransactionResult
• admin::AbortTransactionSpec
• admin::AdminClientConfig
• admin::AlterClientQuotasResult
• admin::AlterConfigsResult
• admin::AlterConsumerGroupOffsetsResult
• admin::AlterPartitionReassignmentsResult
• admin::AlterReplicaLogDirsResult
• admin::AlterUserScramCredentialsResult
• admin::ClassicGroupDescription
• admin::Config
• admin::ConsumerGroupDescription
• admin::CreateAclsResult
• admin::CreateDelegationTokenResult
• admin::CreatePartitionsResult
• admin::DeleteConsumerGroupOffsetsResult
• admin::DeleteConsumerGroupsResult
• admin::DeleteRecordsResult
• admin::DeletedRecords
• admin::DescribeAclsResult
• admin::DescribeClassicGroupsResult
• admin::DescribeClientQuotasResult
• admin::DescribeClusterResult
• admin::DescribeConfigsResult
• admin::DescribeConsumerGroupsResult
• admin::DescribeDelegationTokenResult
• admin::DescribeFeaturesResult
• admin::DescribeLogDirsResult
• admin::DescribeTransactionsResult
• admin::DescribeUserScramCredentialsResult
• admin::ElectLeadersResult
• admin::ExpireDelegationTokenResult
• admin::FeatureMetadata
• admin::FenceProducersResult
• admin::FinalizedVersionRange
• admin::GroupListing
• admin::KafkaAdminClient
• admin::ListConfigResourcesResult
• admin::ListConsumerGroupOffsetsResult
• admin::ListConsumerGroupOffsetsSpec
• admin::ListGroupsResult
• admin::ListPartitionReassignmentsResult
• admin::ListTopicsResult
• admin::ListTransactionsResult
• admin::LogDirDescription
• admin::MemberAssignment
• admin::MemberDescription
• admin::MemberToRemove
• admin::MockAdminClient
• admin::NewPartitionReassignment
• admin::NewPartitions
• admin::NewTopic
• admin::PartitionReassignment
• admin::ProducerState
• admin::RecordsToDelete
• admin::RemoveMembersFromConsumerGroupResult
• admin::RenewDelegationTokenResult
• admin::ReplicaInfo
• admin::ScramCredentialInfo
• admin::SupportedVersionRange
• admin::TerminateTransactionResult
• admin::TopicDescription
• admin::TopicListing
• admin::TransactionDescription
• admin::TransactionListing
• admin::UpdateFeaturesResult
• admin::UserScramCredentialDeletion
• admin::UserScramCredentialUpsertion
• admin::UserScramCredentialsDescription
• admin::alter_config_op::AlterConfigOp
• admin::config_entry::ConfigEntry
• admin::config_entry::ConfigEntryOptions
• admin::config_entry::ConfigEntryOptionsBuilder
• admin::config_entry::ConfigSynonym
• admin::create_topics_result::CreateTopicsResult
• admin::create_topics_result::TopicMetadataAndConfig
• admin::delete_acls_result::DeleteAclsResult
• admin::delete_acls_result::FilterResult
• admin::delete_acls_result::FilterResults
• admin::describe_producers_result::DescribeProducersResult
• admin::describe_producers_result::PartitionProducerState
• admin::describe_replica_log_dirs_result::DescribeReplicaLogDirsResult
• admin::describe_replica_log_dirs_result::ReplicaLogDirInfo
• admin::feature_update::FeatureUpdate
• admin::list_offsets_result::ListOffsetsResult
• admin::list_offsets_result::ListOffsetsResultInfo
• admin::options::AbortTransactionOptions
• admin::options::AlterClientQuotasOptions
• admin::options::AlterConfigsOptions
• admin::options::AlterConsumerGroupOffsetsOptions
• admin::options::AlterPartitionReassignmentsOptions
• admin::options::AlterReplicaLogDirsOptions
• admin::options::AlterUserScramCredentialsOptions
• admin::options::CreateAclsOptions
• admin::options::CreateDelegationTokenOptions
• admin::options::CreatePartitionsOptions
• admin::options::CreateTopicsOptions
• admin::options::DeleteAclsOptions
• admin::options::DeleteConsumerGroupOffsetsOptions
• admin::options::DeleteConsumerGroupsOptions
• admin::options::DeleteRecordsOptions
• admin::options::DeleteTopicsOptions
• admin::options::DescribeAclsOptions
• admin::options::DescribeClassicGroupsOptions
• admin::options::DescribeClientQuotasOptions
• admin::options::DescribeClusterOptions
• admin::options::DescribeConfigsOptions
• admin::options::DescribeConsumerGroupsOptions
• admin::options::DescribeDelegationTokenOptions
• admin::options::DescribeFeaturesOptions
• admin::options::DescribeLogDirsOptions
• admin::options::DescribeProducersOptions
• admin::options::DescribeReplicaLogDirsOptions
• admin::options::DescribeTopicsOptions
• admin::options::DescribeTransactionsOptions
• admin::options::DescribeUserScramCredentialsOptions
• admin::options::ElectLeadersOptions
• admin::options::ExpireDelegationTokenOptions
• admin::options::FenceProducersOptions
• admin::options::ListConfigResourcesOptions
• admin::options::ListConsumerGroupOffsetsOptions
• admin::options::ListGroupsOptions
• admin::options::ListOffsetsOptions
• admin::options::ListPartitionReassignmentsOptions
• admin::options::ListTopicsOptions
• admin::options::ListTransactionsOptions
• admin::options::RemoveMembersFromConsumerGroupOptions
• admin::options::RenewDelegationTokenOptions
• admin::options::TerminateTransactionOptions
• admin::options::UpdateFeaturesOptions
• common::Cluster
• common::ClusterResource
• common::InvalidRecordError
• common::KafkaError
• common::KafkaFuture
• common::LocalConcurrentModificationError
• common::LocalIllegalArgumentError
• common::LocalIllegalStateError
• common::LocalTimeoutError
• common::MetricName
• common::MetricNameTemplate
• common::Node
• common::PartitionInfo
• common::TopicIdPartition
• common::TopicPartition
• common::TopicPartitionInfo
• common::TopicPartitionReplica
• common::Uuid
• common::acl::AccessControlEntry
• common::acl::AccessControlEntryFilter
• common::acl::AclBinding
• common::acl::AclBindingFilter
• common::config::ConfigError
• common::config::SaslConfigs
• common::config::SslConfigs
• common::config::config_resource::ConfigResource
• common::errors::ApiError
• common::errors::AuthenticationError
• common::errors::AuthorizationError
• common::errors::AuthorizerNotReadyError
• common::errors::BrokerIdNotRegisteredError
• common::errors::BrokerNotAvailableError
• common::errors::ClusterAuthorizationError
• common::errors::ConcurrentTransactionsError
• common::errors::ControllerMovedError
• common::errors::CoordinatorLoadInProgressError
• common::errors::CoordinatorNotAvailableError
• common::errors::CorruptRecordError
• common::errors::DelegationTokenAuthorizationError
• common::errors::DelegationTokenDisabledError
• common::errors::DelegationTokenExpiredError
• common::errors::DelegationTokenNotFoundError
• common::errors::DelegationTokenOwnerMismatchError
• common::errors::DisconnectError
• common::errors::DuplicateBrokerRegistrationError
• common::errors::DuplicateResourceError
• common::errors::DuplicateSequenceError
• common::errors::DuplicateVoterError
• common::errors::ElectionNotNeededError
• common::errors::EligibleLeadersNotAvailableError
• common::errors::FeatureUpdateFailedError
• common::errors::FencedInstanceIdError
• common::errors::FencedLeaderEpochError
• common::errors::FencedMemberEpochError
• common::errors::FencedStateEpochError
• common::errors::FetchSessionIdNotFoundError
• common::errors::FetchSessionTopicIdError
• common::errors::GroupAuthorizationError
• common::errors::GroupIdNotFoundError
• common::errors::GroupMaxSizeReachedError
• common::errors::GroupNotEmptyError
• common::errors::GroupSubscribedToTopicError
• common::errors::IllegalGenerationError
• common::errors::IllegalSaslStateError
• common::errors::InconsistentClusterIdError
• common::errors::InconsistentGroupProtocolError
• common::errors::InconsistentTopicIdError
• common::errors::InconsistentVoterSetError
• common::errors::IneligibleReplicaError
• common::errors::InterruptError
• common::errors::InvalidCommitOffsetSizeError
• common::errors::InvalidConfigurationError
• common::errors::InvalidFetchSessionEpochError
• common::errors::InvalidFetchSizeError
• common::errors::InvalidGroupIdError
• common::errors::InvalidOffsetError
• common::errors::InvalidPartitionsError
• common::errors::InvalidPidMappingError
• common::errors::InvalidPrincipalTypeError
• common::errors::InvalidProducerEpochError
• common::errors::InvalidRecordStateError
• common::errors::InvalidRegistrationError
• common::errors::InvalidRegularExpression
• common::errors::InvalidReplicaAssignmentError
• common::errors::InvalidReplicationFactorError
• common::errors::InvalidRequestError
• common::errors::InvalidRequiredAcksError
• common::errors::InvalidSessionTimeoutError
• common::errors::InvalidShareSessionEpochError
• common::errors::InvalidTimestampError
• common::errors::InvalidTopicError
• common::errors::InvalidTxnStateError
• common::errors::InvalidTxnTimeoutError
• common::errors::InvalidUpdateVersionError
• common::errors::InvalidVoterKeyError
• common::errors::KafkaStorageError
• common::errors::LeaderNotAvailableError
• common::errors::ListenerNotFoundError
• common::errors::LogDirNotFoundError
• common::errors::MemberIdRequiredError
• common::errors::MismatchedEndpointTypeError
• common::errors::NetworkError
• common::errors::NewLeaderElectedError
• common::errors::NoReassignmentInProgressError
• common::errors::NotControllerError
• common::errors::NotCoordinatorError
• common::errors::NotEnoughReplicasAfterAppendError
• common::errors::NotEnoughReplicasError
• common::errors::NotLeaderOrFollowerError
• common::errors::OffsetMetadataTooLarge
• common::errors::OffsetMovedToTieredStorageError
• common::errors::OffsetNotAvailableError
• common::errors::OffsetOutOfRangeError
• common::errors::OperationNotAttemptedError
• common::errors::OutOfOrderSequenceError
• common::errors::PolicyViolationError
• common::errors::PositionOutOfRangeError
• common::errors::PreferredLeaderNotAvailableError
• common::errors::PrincipalDeserializationError
• common::errors::ProducerFencedError
• common::errors::ReassignmentInProgressError
• common::errors::RebalanceInProgressError
• common::errors::RebootstrapRequiredError
• common::errors::RecordBatchTooLargeError
• common::errors::RecordTooLargeError
• common::errors::ReplicaNotAvailableError
• common::errors::ResourceNotFoundError
• common::errors::SaslAuthenticationError
• common::errors::SecurityDisabledError
• common::errors::SerializationError
• common::errors::ShareSessionLimitReachedError
• common::errors::ShareSessionNotFoundError
• common::errors::SnapshotNotFoundError
• common::errors::SslAuthenticationError
• common::errors::StaleBrokerEpochError
• common::errors::StaleMemberEpochError
• common::errors::StreamsInvalidTopologyEpochError
• common::errors::StreamsInvalidTopologyError
• common::errors::StreamsTopologyFencedError
• common::errors::TelemetryTooLargeError
• common::errors::ThrottlingQuotaExceededError
• common::errors::TimeoutError
• common::errors::TopicAuthorizationError
• common::errors::TopicDeletionDisabledError
• common::errors::TopicExistsError
• common::errors::TransactionAbortableError
• common::errors::TransactionAbortedError
• common::errors::TransactionCoordinatorFencedError
• common::errors::TransactionalIdAuthorizationError
• common::errors::TransactionalIdNotFoundError
• common::errors::UnacceptableCredentialError
• common::errors::UnknownControllerIdError
• common::errors::UnknownLeaderEpochError
• common::errors::UnknownMemberIdError
• common::errors::UnknownProducerIdError
• common::errors::UnknownServerError
• common::errors::UnknownSubscriptionIdError
• common::errors::UnknownTopicIdError
• common::errors::UnknownTopicOrPartitionError
• common::errors::UnreleasedInstanceIdError
• common::errors::UnstableOffsetCommitError
• common::errors::UnsupportedAssignorError
• common::errors::UnsupportedByAuthenticationError
• common::errors::UnsupportedCompressionTypeError
• common::errors::UnsupportedEndpointTypeError
• common::errors::UnsupportedForMessageFormatError
• common::errors::UnsupportedSaslMechanismError
• common::errors::UnsupportedVersionError
• common::errors::VoterNotFoundError
• common::errors::WakeupError
• common::errors::record_deserialization_error::RecordDeserializationError
• common::header::RecordHeader
• common::header::RecordHeaders
• common::metrics::ClosureGauge
• common::metrics::ClosureMeasurable
• common::metrics::KafkaMetric
• common::metrics::MetricConfig
• common::metrics::Metrics
• common::metrics::NamedMeasurable
• common::metrics::Quota
• common::metrics::QuotaViolationError
• common::metrics::SensorOptions
• common::metrics::SensorOptionsBuilder
• common::metrics::sensor::Sensor
• common::metrics::stats::Avg
• common::metrics::stats::CumulativeCount
• common::metrics::stats::CumulativeSum
• common::metrics::stats::Max
• common::metrics::stats::Meter
• common::metrics::stats::Min
• common::metrics::stats::Rate
• common::metrics::stats::SimpleRate
• common::metrics::stats::Value
• common::metrics::stats::WindowedCount
• common::metrics::stats::WindowedSum
• common::metrics::stats::sampled_stat::Sample
• common::metrics::stats::sampled_stat::SampledStat
• common::quota::ClientQuotaAlteration
• common::quota::ClientQuotaEntity
• common::quota::ClientQuotaFilter
• common::quota::ClientQuotaFilterComponent
• common::quota::Op
• common::resource::Resource
• common::resource::ResourcePattern
• common::resource::ResourcePatternFilter
• common::security::auth::KafkaPrincipal
• common::security::token::delegation::DelegationToken
• common::security::token::delegation::TokenInformation
• common::serialization::ByteArrayDeserializer
• common::serialization::ByteArraySerializer
• common::serialization::BytesDeserializer
• common::serialization::StringDeserializer
• common::serialization::StringSerializer
• consumer::ConsumerCommitFailedError
• consumer::ConsumerConfig
• consumer::ConsumerHandle
• consumer::ConsumerLogTruncationError
• consumer::ConsumerNoOffsetForPartitionError
• consumer::ConsumerOffsetOutOfRangeError
• consumer::ConsumerRecord
• consumer::ConsumerRecordOptions
• consumer::ConsumerRecordOptionsBuilder
• consumer::ConsumerRecords
• consumer::ConsumerRetriableCommitFailedError
• consumer::KafkaConsumer
• consumer::MockConsumer
• consumer::OffsetAndMetadata
• consumer::OffsetAndTimestamp
• consumer::SubscriptionPattern
• consumer::close_options::CloseOptions
• consumer::consumer_partition_assignor::Assignment
• consumer::consumer_partition_assignor::Subscription
• consumer::consumer_partition_assignor::SubscriptionOptions
• consumer::consumer_partition_assignor::SubscriptionOptionsBuilder
• producer::KafkaProducer
• producer::MockProducer
• producer::MockProducerOptions
• producer::MockProducerOptionsBuilder
• producer::ProducerBufferExhaustedError
• producer::ProducerConfig
• producer::ProducerRecord
• producer::ProducerRecordOptions
• producer::ProducerRecordOptionsBuilder
• producer::RecordMetadata
• producer::RoundRobinPartitioner

Enums

• admin::AdminClient
• admin::DeleteTopicsResult
• admin::DescribeTopicsResult
• admin::OffsetSpec
• admin::ScramMechanism
• admin::TransactionState
• admin::UserScramCredentialAlteration
• admin::alter_config_op::OpType
• admin::config_entry::ConfigSource
• admin::config_entry::ConfigType
• admin::feature_update::UpgradeType
• common::ClassicGroupState
• common::ElectionType
• common::Error
• common::GroupState
• common::GroupType
• common::IsolationLevel
• common::MetricValue
• common::TopicCollection
• common::acl::AclOperation
• common::acl::AclPermissionType
• common::config::SslClientAuth
• common::config::config_resource::Type
• common::errors::record_deserialization_error::DeserializationErrorOrigin
• common::metrics::MetricValueProvider
• common::metrics::TimeUnit
• common::metrics::sensor::RecordingLevel
• common::quota::ClientQuotaMatch
• common::record::TimestampType
• common::resource::PatternType
• common::resource::ResourceType
• common::security::auth::SecurityProtocol
• consumer::GroupProtocol
• consumer::close_options::GroupMembershipOperation

Traits

• admin::Admin
• common::ClusterResourceListener
• common::Metric
• common::header::Header
• common::header::Headers
• common::metrics::CompoundStat
• common::metrics::Gauge
• common::metrics::Measurable
• common::metrics::MeasurableStat
• common::metrics::MetricsReporter
• common::metrics::Stat
• common::metrics::stats::sampled_stat::SampledStatKind
• common::serialization::Deserializer
• common::serialization::Serializer
• consumer::Consumer
• consumer::ConsumerGroupMetadata
• consumer::ConsumerInterceptor
• consumer::ConsumerRebalanceListener
• consumer::OffsetCommitCallback
• producer::DynProducer
• producer::Partitioner
• producer::Producer

Macros

• kafka_debug
• kafka_error
• kafka_info
• kafka_trace
• kafka_warn

Type Aliases

• admin::GroupOffsets
• producer::Callback

Constants

• consumer::consumer_partition_assignor::DEFAULT_GENERATION