AdjustOptions adjust the `Options` and `sarama.Config` by condition.

InitMetrics registers all metrics in this file.

NewClusterAdminClientMockImpl news a ClusterAdminClientMockImpl struct with default configurations.

NewKafkaClientID generates kafka client id.

NewMockFactory constructs a Factory with mock implementation.

NewOptions returns a default Kafka configuration.

NewSaramaConfig return the default config and set the according version and metrics.

NewSaramaFactory constructs a Factory with sarama implementation.

NewSaramaMetricsCollector return a kafka metrics collector based on sarama library.

BrokerMessageMaxBytesConfigName specifies the largest record batch size allowed by Kafka brokers.

DefaultMockPartitionNum is the default partition number of default mock topic.

DefaultMockTopicName specifies the default mock topic name.

MinInsyncReplicasConfigName the minimum number of replicas that must acknowledge a write for the write to be considered successful.

NoResponse doesn't send any response, the TCP ACK is all you get.

RefreshMetricsInterval specifies the interval of refresh kafka client metrics.

SASLTypeGSSAPI represents the gssapi mechanism.

SASLTypeOAuth represents the SASL/OAUTHBEARER mechanism (Kafka 2.0.0+).

SASLTypePlaintext represents the plain mechanism.

SASLTypeSCRAMSHA256 represents the SCRAM-SHA-256 mechanism.

SASLTypeSCRAMSHA512 represents the SCRAM-SHA-512 mechanism.

TopicMaxMessageBytesConfigName specifies the largest record batch size allowed by Kafka topics.

Unknown should never have been use in real config.

WaitForAll waits for all in-sync replicas to commit before responding.

WaitForLocal waits for only the local commit to succeed before responding.

BatchDurationGauge only for kafka-go client to track internal batch duration.

BatchMessageCountGauge only for kafka-go client to track each batch's messages count.

BatchSizeGauge only for kafka-go client to track each batch's size in bytes.

BrokerMessageMaxBytes is the broker's `message.max.bytes`.

ClientErrorGauge only for kafka-go client to track internal error count.

ClientRetryGauge only for kafka-go client to track internal retry count.

MinInSyncReplicas is the `min.insync.replicas`.

OutgoingByteRateGauge for outgoing events.

RequestLatencyGauge Histogram update by `requestLatency`.

RequestRateGauge Meter mark by 1 for each request.

TopicMaxMessageBytes is the topic's `max.message.bytes`.

AutoCreateTopicConfig is used to create topic configuration.

Broker represents a Kafka broker.

ClusterAdminClientMockImpl mock implements the admin client interface.

MockFactory is a mock implementation of Factory interface.

MockSaramaAsyncProducer is a mock implementation of AsyncProducer interface.

MockSaramaSyncProducer is a mock implementation of SyncProducer interface.

Options stores user specified configurations.

TopicDetail represent a topic's detail information.

AsyncProducer is the kafka async producer.

ClusterAdminClient is the administrative client for Kafka, which supports managing and inspecting topics, brokers, configurations and ACLs.

Factory is used to produce all kafka components.

MetricsCollector is the interface for kafka metrics collector.

SyncProducer is the kafka sync producer.

FactoryCreator defines the type of factory creator.

RequiredAcks is used in Produce Requests to tell the broker how many replica acknowledgements it must see before responding.