public class SingleTopicSupplier<T> extends Object implements TopicSupplier<T>
Constructor and Description |
---|
SingleTopicSupplier(org.apache.kafka.clients.admin.NewTopic newTopic,
Properties adminClientProperties) |
public SingleTopicSupplier(org.apache.kafka.clients.admin.NewTopic newTopic, Properties adminClientProperties)
public Optional<String> topic(T data)
TopicSupplier
topic
in interface TopicSupplier<T>