我们将Kafka流(2.5.0jar(与java应用程序(具有一次语义(和Jdbc接收器连接器(UPSERT模式(一起用于向数据库写入数据。
流量：-
Java Kafka Stream应用程序------->Db接收器连接器。
akhq用户界面始终显示滞后1，即使所有消息都是有效消息。所有的消息都被消耗掉了。是因为连接器没有"；隔离电平"；作为"；read_committed"，当前"；read_uncommited"；。滞后如下图所示。我也看到一个与卡夫卡有关的错误https://issues.apache.org/jira/browse/KAFKA-10683，与此有关吗。
接收器连接器消费者滞后
问题很晚，但我不知道有人在stackoverflow上问关于akhq的问题。
这是卡夫卡交易的一种行为。Kafka事务使用提交消息处理，Kafka消费者永远不会读取该消息。消费者就是不知道最后一个偏移量是提交。因此，由于Akhq是一个简单的卡夫卡消费者，它总是会看到1的滞后。
每一个使用Kafka事务的应用程序都有这个功能。