在Spring靴Kafka监听器中接收Kafka键

Question

     @KafkaListener(groupId = Bindings.CONSUMER_GROUP_DATA_CLEANUP, topics = "users")
     public void process( @Payload MyMessage myMessage){

        MyExtended myExtendedKey= new MyExtendedKey(myKey.getX(), myKey.getY());
        ....
        ....
        kafkaTemplate.send(TOPIC,  myExtendedKey, message);
      }

我不知道如何才能得到消息的密钥，这是发送在监听器。

Answer 1

请阅读文档。

...

最后，关于消息的元数据可以从消息头获得。您可以使用以下标头名称检索邮件的标头：

KafKaheaders.timestamp_type

下面的示例显示如何使用标头：

java prettyprint-override">@KafkaListener(id = "qux", topicPattern = "myTopic1")
public void listen(@Payload String foo,
        @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) Integer key,
        @Header(KafkaHeaders.RECEIVED_PARTITION_ID) int partition,
        @Header(KafkaHeaders.RECEIVED_TOPIC) String topic,
        @Header(KafkaHeaders.RECEIVED_TIMESTAMP) long ts
        ) {
    ...
}

偏移也是可用的。