Package org.springframework.kafka.jdocs.dynamic

Class MyPojo

  • public class MyPojo
extends java.lang.Object
    Pojo for dynamic listener creation.
    Since:
    2.8.9
    Author:
    Gary Russell

    • Constructor Summary

      Constructors 
      Constructor Description
      MyPojo​(java.lang.String id, java.lang.String topic)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.lang.String getId()  
      java.lang.String getTopic()  
      void listen​(java.lang.String in)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • MyPojo

        public MyPojo​(java.lang.String id,
              java.lang.String topic)

    • Method Detail

      • getId

        public java.lang.String getId()

      • getTopic

        public java.lang.String getTopic()

      • listen

        @KafkaListener(id="#{__listener.id}",
               topics="#{__listener.topic}")
public void listen​(java.lang.String in)