Schlüssel ist erforderlich als Teil für das senden von Nachrichten an Kafka?

KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(), SerializationUtils.serialize(message)); 
producer.send(keyedMessage);

Derzeit, ich bin das senden von Nachrichten, ohne den Schlüssel als Teil des keyed-Nachrichten, wird es immer noch funktionieren mit delete.retention.ms? Brauche ich zum senden einer Taste als Teil der Nachricht? Ist diese gut zu machen, um den Schlüssel als Teil der Nachricht?

InformationsquelleAutor gaurav | 2015-04-08
Schreibe einen Kommentar