Categorygithub.com/ricardo-ch/kafka-topic-clonerkafka
package
0.7.1
Repository: https://github.com/ricardo-ch/kafka-topic-cloner.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
5
Dependents
2
Files
178 SLOC

# Functions

MurmurHasher creates murmur2 hasher implementing hash.Hash32 interface.
NewConsumer configures and returns a cluster-consumer.
NewJVMCompatiblePartitioner creates a Sarama partitioner that uses the same hashing algorithm as JVM Kafka clients.
NewProducer configures and returns an async producer.