public class ProducedInternal<K,V> extends Produced<K,V>
keySerde, partitioner, valueSerde
Constructor and Description |
---|
ProducedInternal(Produced<K,V> produced) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<K> |
keySerde() |
StreamPartitioner<? super K,? super V> |
streamPartitioner() |
org.apache.kafka.common.serialization.Serde<V> |
valueSerde() |
equals, hashCode, keySerde, streamPartitioner, valueSerde, with, with, withKeySerde, withStreamPartitioner, withValueSerde
public org.apache.kafka.common.serialization.Serde<K> keySerde()
public org.apache.kafka.common.serialization.Serde<V> valueSerde()
public StreamPartitioner<? super K,? super V> streamPartitioner()