PartitionAssignor for Apache Kafka This project contains examples to implement a custom PartitionAssignor for Apache Kafka consumer-client.