Related questions
How to check whether Kafka Server is running?
I want to ensure whether kafka server is running or not before starting production and consumption jobs. It is in windows environment and here's my kafka server's code in eclipse...
Properties kafka = new Properties();
kafka.setProperty("broker.id", "1");
kafka.setProperty("…
Understanding Kafka Topics and Partitions
I am starting to learn Kafka for enterprise solution purposes.
During my readings, some questions came to my mind:
When a producer is producing a message - it will specify the topic it wants to send the message to, is …
Is key required as part of sending messages to Kafka?
KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(), SerializationUtils.serialize(message));
producer.send(keyedMessage);
Currently, I am sending messages without any key as part of keyed messages, will it still work with delete.retention.…