Replies: 1 comment
-
The abort marker messages (12 and 13) will be ignored and not passed to the application, so unless there are more messages being produced to the partition the consumer will not return any new messages (and thus time out according to your timeout argument) |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
When there are aborted Kafka transactions in the topic, the messages may be with discontinuous offsets.
Suppose we have kafka message as following:
The
query_watermark_offsets
would return low/high as 10/13.But, the
Message *consume (int timeout_ms)
would hangs at offset 12 and returnsRdKafka::ERR__TIMED_OUT
.What I expect is that the
consume
could reach the offset 13 and return empty message.Is it by design or something wrong with my config?
Beta Was this translation helpful? Give feedback.
All reactions