StaticTopicNameExtractor (kafka 2.6.1.100-eep-810 API)

java.lang.Object
- org.apache.kafka.streams.processor.internals.StaticTopicNameExtractor<K,V>

All Implemented Interfaces:: TopicNameExtractor<K,V>

public class StaticTopicNameExtractor<K,V>
extends Object
implements TopicNameExtractor<K,V>

Static topic name extractor

Field Summary

Fields
Modifier and Type Field Description

String topicName

Constructor Summary

Constructors
Constructor Description

StaticTopicNameExtractor(String topicName)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`equals(Object o)`
`String`	`extract(K key, V value, RecordContext recordContext)`	Extracts the topic name to send to.
`int`	`hashCode()`
`String`	`toString()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

- Field Detail
  - topicName
```
public final String topicName
```
- Constructor Detail
  - StaticTopicNameExtractor
```
public StaticTopicNameExtractor(String topicName)
```
- Method Detail
  - extract
```
public String extract(K key,
                      V value,
                      RecordContext recordContext)
```
    Description copied from interface: TopicNameExtractor
    
    Extracts the topic name to send to. The topic name must already exist, since the Kafka Streams library will not try to automatically create the topic with the extracted name.
    
    Specified by:
    
    extract in interface TopicNameExtractor<K,V>
    
    Parameters:
    
    key - the record key
    
    value - the record value
    
    recordContext - current context metadata of the record
    
    Returns:
    
    the topic name this record should be sent to
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - equals
```
public boolean equals(Object o)
```
    Overrides:
    
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object