相关疑难解决方法(0)

是否需要密钥作为向Kafka发送消息的一部分?

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

目前,我发送的消息没有任何密钥作为键控消息的一部分,它仍然可以使用delete.retention.ms吗?我是否需要发送密钥作为邮件的一部分?将密钥作为消息的一部分是否合适?

apache-kafka kafka-consumer-api

70
推荐指数
2
解决办法
5万
查看次数

标签 统计

apache-kafka ×1

kafka-consumer-api ×1