Skip to content

Commit 0b248e3

Browse files
committed
Fix typos in streams documentation
Signed-off-by: Khan, C M Abdullah <cmabdullah21@gmail.com>
1 parent 558453b commit 0b248e3

File tree

1 file changed

+3
-3
lines changed
  • spring-kafka-docs/src/main/antora/modules/ROOT/pages

1 file changed

+3
-3
lines changed

spring-kafka-docs/src/main/antora/modules/ROOT/pages/streams.adoc

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ When constructing the serializer/deserializer programmatically for use in the pr
165165
[source, java]
166166
----
167167
stream.through(
168-
new JackonJsonSerde<>(MyKeyType.class)
168+
new JacksonJsonSerde<>(MyKeyType.class)
169169
.forKeys()
170170
.noTypeInfo(),
171171
new JacksonJsonSerde<>(MyValueType.class)
@@ -225,7 +225,7 @@ If there are multiple such beans, they will be applied according to their `Order
225225

226226
When the factory is stopped, the `KafkaStreams.close()` is called with 2 parameters :
227227

228-
* closeTimeout : how long to to wait for the threads to shutdown (defaults to `DEFAULT_CLOSE_TIMEOUT` set to 10 seconds). Can be configured using `StreamsBuilderFactoryBean.setCloseTimeout()`.
228+
* closeTimeout : how long to wait for the threads to shutdown (defaults to `DEFAULT_CLOSE_TIMEOUT` set to 10 seconds). Can be configured using `StreamsBuilderFactoryBean.setCloseTimeout()`.
229229
* leaveGroupOnClose : to trigger consumer leave call from the group (defaults to `false`). Can be configured using `StreamsBuilderFactoryBean.setLeaveGroupOnClose()`.
230230

231231
By default, when the factory bean is stopped, the `KafkaStreams.cleanUp()` method is called.
@@ -352,7 +352,7 @@ public KafkaStreamsInteractiveQueryService kafkaStreamsInteractiveQueryService(S
352352
}
353353
----
354354

355-
Assuming that a Kafka Streams application has a state store called `app-store`, then that store can be retrieved via the `KafkStreamsInteractiveQuery` API as show below.
355+
Assuming that a Kafka Streams application has a state store called `app-store`, then that store can be retrieved via the `KafkaStreamsInteractiveQuery` API as shown below.
356356

357357
[source, java]
358358
----

0 commit comments

Comments
 (0)