Priorization in Kafka

Sample code containing a producer and consumer using the bucket priority pattern implementation.

Running

- Update the configuration

cd src/main/resources
cp kafka.properties.example kafka.properties
vim kafka.properties

- Building the project

mvn clean package

- Running the regular producer

java -cp <CLASSPATH> io.confluent.kafka.demo.AllOrdersProducer

- Running the bucket-based producer

java -cp <CLASSPATH> io.confluent.kafka.demo.BucketBasedProducer

- Running the regular consumer

java -cp <CLASSPATH> io.confluent.kafka.demo.AllOrdersConsumer <NUMBER_OF_THREADS>

- Running the bucket-based consumer

java -cp <CLASSPATH> io.confluent.kafka.demo.BucketBasedConsumer <BUCKET_NAME> <NUMBER_OF_THREADS>

License

This project is licensed under the Apache 2.0 License.