THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
public class Grouped<K, V> {
protected final Serde<K> keySerde;
protected final Serde<V> valueSerde;
protected final String name;
protected final Integer 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 number of partitions, KStream application will first issue the topic lookup request and check whether the target topic is already up and running. If the target topic already exists, KStream application will log the error for topic creation failure, and still continue the initialization.
...
This is a pure KStream library change that shouldn't affect previous previously setup applications.
Rejected Alternatives
...