Package kafkamock is a generated GoMock package.

DefaultConfig creates a new config used per default.

ParseBalanceStrategy return BalanceStrategy from assignor.

ParsePartitioner return PartitionerConstructor from scheme.

WithProducerPartitioner use partitioner to generates partition to send messages to (defaults to hashing the message key).

SASLExtKeyAuth is the reserved extension key name sent as part of the SASL/OAUTHBEARER initial client response.

SASLHandshakeV0 is v0 of the Kafka SASL handshake protocol.

SASLHandshakeV1 is v1 of the Kafka SASL handshake protocol.

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

SASLTypePlaintext represents the SASL/PLAIN mechanism.

SASLTypeSCRAMSHA256 represents the SCRAM-SHA-256 mechanism.

SASLTypeSCRAMSHA512 represents the SCRAM-SHA-512 mechanism.

AdminConfig is the namespace for ClusterAdmin properties used by the administrative Kafka client.

Config is the configuration for Kafka.

ConsumerHandler represents a Sarama consumer group consumer.

ConsumerOffsets specifies configuration for how and when to commit consumed offsets.

SASL based authentication with broker.

go:generate mockgen -destination=./mocks/$GOFILE -source=$GOFILE -package=kafkamock Algorithm determines the hash function used by SCRAM to protect the user's credentials.

go:generate mockgen -destination=./mocks/$GOFILE -source=$GOFILE -package=kafkamock.

go:generate mockgen -destination=./mocks/$GOFILE -source=$GOFILE -package=kafkamock.

ConsumerHandlerFn is invoked for each message received by consumer.