kafka consumer get current position #3973
Unanswered
Sunnycheey
asked this question in
Q&A
Replies: 0 comments
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.
-
Hi, I create
TopicPartition
vectorv1
and assign it to a kafka consumer. Currently, I want useposition
function to retrieve current offset of the KafkaConsumer. Can I callposition
directly onv1
, or need I get assignmentv2
of the KafkaConsumer first and then callpostition
onv2
sinceposition
call will change the input TopicPartition vector.Beta Was this translation helpful? Give feedback.
All reactions