This project contains examples to implement a custom PartitionAssignor for Apache Kafka consumer-client.
streamthoughts/kafka-consumer-partition-assignor
This project contains examples to implement a custom PartitionAssignor for Apache Kafka consumer-client.
JavaApache-2.0