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
-
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