Partitioning based consumer not working

[codewheeney]

I was bringing this code into my project, and writing some POC tests and the partitioning based producer works just fine in my project, but the consumer based one keeps hanging.

To verify, I started up the docker container as described here: https://community.aws/posts/prioritizing-event-processing-with-apache-kafka

and the producer example code, via

java -cp target/bucket-priority-pattern-1.0.0-jar-with-dependencies.jar blog.buildon.aws.streaming.kafka.BucketBasedProducer

works just fine, but the consumer based example code found in here:

java -cp target/bucket-priority-pattern-1.0.0-jar-with-dependencies.jar blog.buildon.aws.streaming.kafka.BucketBasedConsumer Platinum 5

I'm continuing to debug in my project, and I confirmed so far that the records are being sent, but none delivered to any listeners.