我们一直在使用卡夫卡,我们面临的问题是负面卡夫卡太高。在Kafka中,如何使当前偏移量为4933973245,而日志结束偏移量仅为1924,从而导致负Kafka滞后?
可能正因为如此,一些消息甚至没有在Java使用者中使用。
这可能是配置问题吗?有什么见解吗?
我们正在使用Spring Kafka。