File tree Expand file tree Collapse file tree 1 file changed +15
-0
lines changed
spring-kafka/src/main/java/org/springframework/kafka/config Expand file tree Collapse file tree 1 file changed +15
-0
lines changed Original file line number Diff line number Diff line change 3636public interface KafkaStreamsCustomizer {
3737
3838 /**
39+ * Customize the instantiation of the {@code KafkaStreams} instance. This
40+ * happens before the modifications made by {@link StreamsBuilderFactoryBean}.
41+ *
42+ * @param topology the full topology
43+ * @param properties the configuration properties
44+ * @param clientSupplier the client supplier
45+ *
46+ * @return a new instance of {@link KafkaStreams}
47+ *
3948 * @since 3.3.0
4049 */
4150 default KafkaStreams initKafkaStreams (
@@ -46,6 +55,12 @@ default KafkaStreams initKafkaStreams(
4655 return new KafkaStreams (topology , properties , clientSupplier );
4756 }
4857
58+ /**
59+ * Customize the instance of {@code KafkaStreams} after {@link StreamsBuilderFactoryBean}
60+ * has applied its default configurations.
61+ *
62+ * @param kafkaStreams the instantiated Kafka Streams instance
63+ */
4964 void customize (KafkaStreams kafkaStreams );
5065
5166}
You can’t perform that action at this time.
0 commit comments