Skip to content

Commit dfe9f48

Browse files
xoronetgaryrussell
authored andcommitted
Corrects two typos
corrects two small typos in the documentation.
1 parent 452ec6c commit dfe9f48

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/reference/asciidoc/kafka.adoc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3352,7 +3352,7 @@ Received test
33523352

33533353
Version 2.1.3 added `pause()` and `resume()` methods to listener containers.
33543354
Previously, you could pause a consumer within a `ConsumerAwareMessageListener` and resume it by listening for a `ListenerContainerIdleEvent`, which provides access to the `Consumer` object.
3355-
While you could pause a consumer in an idle container byi using an event listener, in some cases, this was not thread-safe, since there is no guarantee that the event listener is invoked on the consumer thread.
3355+
While you could pause a consumer in an idle container by using an event listener, in some cases, this was not thread-safe, since there is no guarantee that the event listener is invoked on the consumer thread.
33563356
To safely pause and resume consumers, you should use the `pause` and `resume` methods on the listener containers.
33573357
A `pause()` takes effect just before the next `poll()`; a `resume()` takes effect just after the current `poll()` returns.
33583358
When a container is paused, it continues to `poll()` the consumer, avoiding a rebalance if group management is being used, but it does not retrieve any records.
@@ -3640,7 +3640,7 @@ DefaultKafkaConsumerFactory<Integer, Cat1> cf = new DefaultKafkaConsumerFactory<
36403640

36413641
Starting with version 2.5, you can now configure the deserializer, via properties, to invoke a method to determine the target type.
36423642
If present, this will override any of the other techniques discussed above.
3643-
This can be useful if the data is published by an application that does not use the Spring serializer and you need to deserializer to different types depending on the data, or other headers.
3643+
This can be useful if the data is published by an application that does not use the Spring serializer and you need to deserialize to different types depending on the data, or other headers.
36443644
Set these properties to the method name - a fully qualified class name followed by the method name, separated by a period `.`.
36453645
The method must be declared as `public static`, have one of two signatures `(byte[] data, Headers headers)` or `(byte[] data)` and return a Jackson `JavaType`.
36463646

0 commit comments

Comments
 (0)