@Evolving public interface TopicNameExtractor<K,V>
Modifier and Type | Method | Description |
---|---|---|
java.lang.String |
extract(K key,
V value,
RecordContext recordContext) |
Extracts the topic name to send to.
|
java.lang.String extract(K key, V value, RecordContext recordContext)
key
- the record keyvalue
- the record valuerecordContext
- current context metadata of the record