Package org.apache.kafka.streams.kstream.internals

Class ProducedInternal<K,V>

java.lang.Object

org.apache.kafka.streams.kstream.Produced<K,V>

org.apache.kafka.streams.kstream.internals.ProducedInternal<K,V>

public class ProducedInternal<K,V>
extends Produced<K,V>

Field Summary

Fields inherited from class org.apache.kafka.streams.kstream.Produced

keySerde, partitioner, processorName, valueSerde

Constructor Summary

Constructors

Constructor	Description
ProducedInternal(Produced<K,V> produced)

Method Summary

Modifier and Type	Method	Description
Serde<K>	keySerde()
String	name()
StreamPartitioner<? super K,? super V>	streamPartitioner()
Serde<V>	valueSerde()

Methods inherited from class org.apache.kafka.streams.kstream.Produced

as, equals, hashCode, keySerde, streamPartitioner, valueSerde, with, with, withKeySerde, withName, withStreamPartitioner, withValueSerde

Methods inherited from class java.lang.Object

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

Constructor Detail

ProducedInternal

public ProducedInternal(Produced<K,V> produced)

Method Detail

keySerde

public Serde<K> keySerde()

valueSerde

public Serde<V> valueSerde()

streamPartitioner

public StreamPartitioner<? super K,? super V> streamPartitioner()

name

public String name()