Skip to content
Snippets Groups Projects

enable topic optimization

9 files
+ 27
18
Compare changes
  • Side-by-side
  • Inline
Files
9
@@ -110,14 +110,15 @@ public abstract class KafkaStreamsBuilder {
@@ -110,14 +110,15 @@ public abstract class KafkaStreamsBuilder {
*
*
* @return A {@code Topology} for a {@code KafkaStreams} application.
* @return A {@code Topology} for a {@code KafkaStreams} application.
*/
*/
protected abstract Topology buildTopology();
protected abstract Topology buildTopology(Properties properties);
/**
/**
* Builds the {@link KafkaStreams} instance.
* Builds the {@link KafkaStreams} instance.
*/
*/
public KafkaStreams build() {
public KafkaStreams build() {
// Create the Kafka streams instance.
// Create the Kafka streams instance.
return new KafkaStreams(this.buildTopology(), this.buildProperties());
final Properties properties = this.buildProperties();
 
return new KafkaStreams(this.buildTopology(properties), properties);
}
}
}
}
Loading