github.com/IBM/sarama @v1.50.3 sqlite

Partitioner is anything that, given a Kafka message and a number of partitions indexed [0...numPartitions-1], decides to [6 implem

-------------------------------------------------------------------- ConsumerGroupHandler instances are used to handle i [9 implem

MockResponse is a response builder interface it defines one method that allows generating a response based on a request [45 imple

-------------------------------------------------------------------- BalanceStrategy is used to balance topics and parti [4 implem

Consumer manages PartitionConsumers which process Kafka messages from brokers. You MUST call Close() on a consumer to av [2 implem

SyncProducer publishes Kafka messages, blocking until they have been acknowledged. It routes messages to the correct bro [2 implem

AccessTokenProvider is the interface that encapsulates how implementors can generate access tokens for Kafka broker auth [2 implem

ProducerInterceptor allows you to intercept (and possibly mutate) the records received by the producer before they are p [2 implem

called by 812

called by 590

called by 485

called by 449

called by 433

called by 266