I have been working on Kafka consumer, producer and Kafka stream application using java since last 1 and half year.
I wrote 4 days because I don’t know actually anything about your application but it should be done sooner than this as you mention, it’s small app.
If you are interested, ping me with details of your application. Like, what kind of configuration you want, or I can suggest as per your requirements?, what kind of record producer need to send?, if required, naming conventions of Kafka topic, java class?