-
|
Kafka Java Consumer API provides an interface, but the C/C++ Consumer API did not find the corresponding interface? |
Beta Was this translation helpful? Give feedback.
Replies: 2 comments 7 replies
-
Beta Was this translation helpful? Give feedback.
-
|
The librdkafka consumer provides up to date consumer_lag in its metrics (https://github.com/edenhill/librdkafka/blob/master/STATISTICS.md). |
Beta Was this translation helpful? Give feedback.
-
|
How to get the offset that has been submitted? |
Beta Was this translation helpful? Give feedback.
-
|
committed() |
Beta Was this translation helpful? Give feedback.
-
|
tks！But I can't find the function in rdkafka.h |
Beta Was this translation helpful? Give feedback.
-
|
https://github.com/edenhill/librdkafka/blob/master/src/rdkafka.h#L4073 |
Beta Was this translation helpful? Give feedback.
-
|
tks very much! |
Beta Was this translation helpful? Give feedback.
The librdkafka consumer provides up to date consumer_lag in its metrics (https://github.com/edenhill/librdkafka/blob/master/STATISTICS.md).