THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
public class Produced<K, V> { protected Serde<K> keySerde; protected Serde<V> valueSerde; protected StreamPartitioner<? super K, ? super V> partitioner; protected Stringboolean topicNamecreateTopic; // new protected Integer numPartitions; // new public static <K, V> Produced<K, V> with(final Serde<K> keySerde, final Serde<V> valueSerde, final StreamPartitioner<? super K, ? super V> partitioner, final Stringboolean topicNamecreateTopic, final Integer numPartitions); } |
...