librdkafka icon indicating copy to clipboard operation
librdkafka copied to clipboard

Consumer Lag for transactional message

Open hgdhot opened this issue 2 years ago • 0 comments

Description

when set enable.auto.commit as false, manually commit the received messages, the consumer lag keeps to be 1 , it seems like the transaction control message is not commited, because of the application didn't receive the control message, how can the application commit it?

How to reproduce

  • Produce message to test topic via transaction;
  • consume from the test topic, using enable.auto.commit=false;
  • commit received messages manually; c255ac12d54eabf524b4001a2405b15c

Checklist

  • [x] librdkafka version (release number or git tag): V1.6.0.3
  • [x] Apache Kafka version: 2.2.0
  • [x] librdkafka client configuration: enable.auto.commit=false

hgdhot avatar Jul 20 '22 07:07 hgdhot