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 booleanfinal String createTopicname; // new
, representing topic name
protected final IntegerString 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 boolean createTopicname,
final Integer numPartitions);
} |
We also plan to want to expand Grouped API with a numPartition configuration
| Code Block | ||||
|---|---|---|---|---|
| ||||
public class Grouped<K, V> {
protected final Serde<K> keySerde;
protected final Serde<V> valueSerde;
protected final String name;
protected final String numPartitions; // new
public static <K, V> Grouped<K, V> with(final String name,
final Serde<K> keySerde,
final Serde<V> valueSerde,
final Integer numPartitions);
}
|
Proposed Changes
When configured with topic name and partition, KStream application will first issue the topic lookup request and check whether the target topic is already up and running.
...