美文网首页
0007.使用@KafkaListener注解的方法可以使用的参

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

作者: 笑着字太黑 | 来源:发表于2022-04-16 22:56 被阅读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) ;

相关文章

网友评论

      本文标题:0007.使用@KafkaListener注解的方法可以使用的参

      本文链接:https://www.haomeiwen.com/subject/xpsqertx.html