make strings and byte slices encodable for convenience so they can be used as keys and/or values in kafka messages StringEncoder implements the Encode

ByteEncoder implements the Encoder interface for Go byte slices so that they can be used as the Key or Value in a ProducerMessage.

ConfigurationError is the type of error returned from a constructor (e.g. NewClient, or NewConsumer) when the specified configuration is invalid.

KError is the type of error that can be returned directly by the Kafka broker. See https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Ka

ConfigResourceType is a type for resources that have configs.

CompressionCodec represents the various compression codecs recognized by Kafka in messages.

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

make []int32 sortable so we can sort partition numbers

taggedFieldValue adapts an encode closure for encode(); tagged-field values are always compact-encoded, so it reports itself as flexible

decoder is the interface that wraps the basic Decode method. Anything implementing Decoder can be extracted from bytes using Kafka's encoding rules.

AccessToken contains an access token used to authenticate a SASL/OAUTHBEARER client along with associated metadata.

AccessTokenProvider is the interface that encapsulates how implementers can generate access tokens for Kafka broker authentication.

Acl holds information about acl type

AclCreation is a wrapper around Resource and Acl type

AclCreationResponse is an acl creation response type

AddOffsetsToTxnRequest adds offsets to a transaction request

AddOffsetsToTxnResponse is a response type for adding offsets to txns

AddPartitionsToTxnRequest is a add partition request

AddPartitionsToTxnResponse is a partition errors to transaction type

AlterClientQuotas Request (Version: 0) => [entries] validate_only entries => [entity] [ops] entity => entity_type entity_name entity_type => STRING en

AlterClientQuotas Response (Version: 0) => throttle_time_ms [entries] throttle_time_ms => INT32 entries => error_code error_message [entity] error_cod

AlterConfigsRequest is an alter config request type

AlterConfigsResource is an alter config resource type

AlterConfigsResourceResponse is a response type for alter config resource

AlterConfigsResponse is a response type for alter config

AlterConsumerGroupOffsetsOptions configures how offsets are committed. It is currently empty and reserved for future Kafka protocol options

ApiVersionsResponseKey contains the APIs supported by the broker.

AsyncProducer publishes Kafka messages using a non-blocking API. It routes messages to the correct broker for the provided topic-partition, refreshing

AsyncProducer implements sarama's Producer interface for testing purposes. Before you can send messages to it's Input channel, you have to set expecta

-------------------------------------------------------------------- BalanceStrategy is used to balance topics and partitions across members of a cons

BalanceStrategyPlan is the results of any BalanceStrategy.Plan attempt. It contains an allocation of topic/partitions by memberID in the form of a `me

Broker represents a single Kafka broker connection. All operations on this object are entirely concurrency-safe.

Client is a generic Kafka client. It manages connections to one or more Kafka brokers. You MUST call Close() on a client to avoid leaks, it will not b

ClusterAdmin is the administrative client for Kafka, which supports managing and inspecting topics, brokers, configurations and ACLs. The minimum brok

Config is used to pass multiple configuration options to Sarama's constructors.

ConfigResourceResult is the described configuration for a single resource.

Consumer manages PartitionConsumers which process Kafka messages from brokers. You MUST call Close() on a consumer to avoid leaks, it will not be garb

Consumer implements sarama's Consumer interface for testing purposes. Before you can start consuming from this consumer, you have to register topic/pa

Consumer represents a Sarama consumer group consumer

Consumer is a minimal ConsumerGroupHandler that also tracks an in-flight counter so it can report a meaningful load sample.

Consumer represents a Sarama consumer group consumer

ConsumerError is what is provided to the user when an error occurs. It wraps an error and includes the topic and partition.

ConsumerErrors is a type that wraps a batch of errors and implements the Error interface. It can be returned from the PartitionConsumer's Close method

ConsumerGroup is responsible for dividing up processing of topics and partitions over a collection of processes (the members of the consumer group).

ConsumerGroupClaim processes Kafka messages from a given topic and partition within a consumer group.

-------------------------------------------------------------------- ConsumerGroupHandler instances are used to handle individual topic/partition clai

ConsumerGroupMemberAssignment holds the member assignment for a consume group https://github.com/apache/kafka/blob/trunk/clients/src/main/resources/co

ConsumerGroupMemberMetadata holds the metadata for consumer group https://github.com/apache/kafka/blob/trunk/clients/src/main/resources/common/message

ConsumerGroupMetadata identifies the consumer group, and optionally the group member, on whose behalf offsets are committed within a transaction. Whe

ConsumerGroupSession represents a consumer group member session.

ConsumerInterceptor allows you to intercept (and possibly mutate) the records received by the consumer before they are sent to the messages channel. h

ConsumerMessage encapsulates a Kafka message returned by the consumer.

ConsumerMetadataRequest is used for metadata requests

ConsumerMetadataResponse holds the response for a consumer group meta data requests

Control records are returned as a record by fetchRequest However unlike "normal" records, they mean nothing application wise. They only serve internal

ControlRecordType ...

CreatableTopicConfigs contains a Configuration of the topic.

CreatableTopicResult struct {

CreateAclsRequest is an acl creation request

CreateAclsResponse is a an acl response creation type