Skip to content

Commit 2580664

Browse files
authored
GH-810: Add StreamsBuilderFB.setCleanupConfig()
Fixes #810
1 parent 43742ab commit 2580664

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

spring-kafka/src/main/java/org/springframework/kafka/config/StreamsBuilderFactoryBean.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ public class StreamsBuilderFactoryBean extends AbstractFactoryBean<StreamsBuilde
7575

7676
private Properties properties;
7777

78-
private final CleanupConfig cleanupConfig;
78+
private CleanupConfig cleanupConfig;
7979

8080
private final List<Listener> listeners = new ArrayList<>();
8181

@@ -234,6 +234,11 @@ public int getPhase() {
234234
return this.phase;
235235
}
236236

237+
public void setCleanupConfig(CleanupConfig cleanupConfig) {
238+
Assert.notNull(cleanupConfig, CLEANUP_CONFIG_MUST_NOT_BE_NULL);
239+
this.cleanupConfig = cleanupConfig;
240+
}
241+
237242
/**
238243
* Get a managed by this {@link StreamsBuilderFactoryBean} {@link KafkaStreams} instance.
239244
* @return KafkaStreams managed instance;

0 commit comments

Comments
 (0)