Hi,
Kafka is installed in CentOs machine. Kafka version is 2.4.0.
I have written sample java code which consumes data from topic. I am using
@KafkaListener(topics = "Device")
public void receive(final String record) {
System.out.println(record);
}
This annotation is mapped with one function(recieve) and data which is present
on topic Device will be mapped to functional argument(record).
I have executed on my local machine and data is coming to variable record. Now
I have created the jar file and ran it on centos machine. Where the kafka
itself is running. While I am pushing data to kafka, my jar file is not getting
the data until and unless I am pressing any key from keyboard. Please let me
know any information is required from my side.
