0007.使用@KafkaListener注解的方法可以使用的参

2022-04-16  本文已影响0人  笑着字太黑

想要取得全部信息的话可以使用ConsumerRecord,
这里包含了header,topic,partition等等全部的信息。

// 以下列举使用@KafkaListener注解的方法可以使用的参数
public interface KafkaListenMethodType<K,V> {
    public void listen1(String data);

    public void listen2(ConsumerRecord<K,V> data);

    public void listen3(ConsumerRecord<K,V> data, Acknowledgment acknowledgment);

    public void listen4(ConsumerRecord<K,V> data, Acknowledgment acknowledgment, Consumer<K,V> consumer);

    public void listen5(List<String> data);

    public void listen6(List<ConsumerRecord<K,V>> data);

    public void listen7(List<ConsumerRecord<K,V>> data, Acknowledgment acknowledgment);

    public void listen8(List<ConsumerRecord<K,V>> data, Acknowledgment acknowledgment, Consumer<K,V> consumer);

public void listen(ConsumerRecord<String,String> data, @Header(KafkaHeaders.GROUP_ID) String groupId) ;
上一篇 下一篇

猜你喜欢

热点阅读