I am new to Kafka that's the reason asking so many question KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(),SerializationUtils.serialize(message)); producer.send(keyedMessage);
Currently,I am sending message without any key maintained as part of keyed message , will it still work with delete.retention.ms ,Do i need to send key as part of message? Is this good to make key as part of message. There are couple of question on this : First Question , Can we consume the message on the key basis , Currently i am consuming message from MessagAndMetadata mm . or is it fine to ignore key at the time of consuming message.I am using hig Level Consumer Api.
