diff --git a/src/reference/asciidoc/kafka.adoc b/src/reference/asciidoc/kafka.adoc index cadb3a25..0987b996 100644 --- a/src/reference/asciidoc/kafka.adoc +++ b/src/reference/asciidoc/kafka.adoc @@ -679,7 +679,8 @@ When using Spring Boot: [source] ---- -spring.kafka.consumer.properties.partition.assignment.strategy=org.apache.kafka.clients.consumer.RoundRobinAssignor +spring.kafka.consumer.properties.partition.assignment.strategy=\ +org.apache.kafka.clients.consumer.RoundRobinAssignor ---- ==== diff --git a/src/reference/asciidoc/streams.adoc b/src/reference/asciidoc/streams.adoc index b8ea3243..dfb73af6 100644 --- a/src/reference/asciidoc/streams.adoc +++ b/src/reference/asciidoc/streams.adoc @@ -115,6 +115,7 @@ stream.through(Serdes.Integer(), new JsonSerde<>(Foo.class), "foos"); IMPORTANT: Since Kafka Streams do not support headers, the `addTypeInfo` property on the `JsonSerializer` is ignored. +[[streams-config]] ==== Configuration To configure the Kafka Streams environment, the `StreamsBuilderFactoryBean` requires a `KafkaStreamsConfiguration` instance. @@ -139,7 +140,7 @@ Putting it all together: @Configuration @EnableKafka @EnableKafkaStreams -public static class KafkaStreamsConfiguration { +public static class KafkaStreamsConfig { @Bean(name = KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME) public KafkaStreamsConfiguration kStreamsConfigs() { diff --git a/src/reference/asciidoc/whats-new.adoc b/src/reference/asciidoc/whats-new.adoc index 4c52aca1..cd31ddfa 100644 --- a/src/reference/asciidoc/whats-new.adoc +++ b/src/reference/asciidoc/whats-new.adoc @@ -84,11 +84,11 @@ See <> for more information. ==== Kafka Streams Changes -The streams configuration bean must now be a simple `Properties` object instead of a `StreamsConfig`. +The streams configuration bean must now be a `KafkaStreamsConfiguration` object instead of a `StreamsConfig`. The `StreamsBuilderFactoryBean` has been moved from package `...core` to `...config`. -See <> for more information. +See <> and <> for more information. ==== Transactional Id