Package org.springframework.kafka.jdocs.dynamic

Class MyPojo

java.lang.Object

org.springframework.kafka.jdocs.dynamic.MyPojo

public class MyPojo
extends Object

Pojo for dynamic listener creation.

Since:

2.8.9

Author:

Gary Russell

Constructor Summary

Constructors

Constructor	Description
MyPojo(String id, String topic)

Method Summary

Modifier and Type	Method	Description
String	getId()
String	getTopic()
void	listen(String in)

Methods inherited from class java.lang.Object

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

Constructor Details

MyPojo

public MyPojo(String id,
 String topic)

Method Details

getId

public String getId()

getTopic

public String getTopic()

listen

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