Doc fixes
This commit is contained in:
@@ -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
|
||||
----
|
||||
====
|
||||
|
||||
|
||||
@@ -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() {
|
||||
|
||||
@@ -84,11 +84,11 @@ See <<serdes>> 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 <<kafka-streams>> for more information.
|
||||
See <<kafka-streams>> and <<streams-config>> for more information.
|
||||
|
||||
|
||||
==== Transactional Id
|
||||
|
||||
Reference in New Issue
Block a user