public class StaticTopicNameExtractor<K,V> extends java.lang.Object implements TopicNameExtractor<K,V>
Modifier and Type | Field and Description |
---|---|
java.lang.String |
topicName |
Constructor and Description |
---|
StaticTopicNameExtractor(java.lang.String topicName) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
extract(K key,
V value,
RecordContext recordContext)
Extracts the topic name to send to.
|
java.lang.String |
toString() |
public StaticTopicNameExtractor(java.lang.String topicName)
public java.lang.String extract(K key, V value, RecordContext recordContext)
TopicNameExtractor
extract
in interface TopicNameExtractor<K,V>
key
- the record keyvalue
- the record valuerecordContext
- current context metadata of the recordpublic java.lang.String toString()
toString
in class java.lang.Object