这是关于让生产者知道消息是否已被消费者消费的用例。
我的想法是，每次消费消息时，消费者提交偏移量，生产者可以跟踪和读取当前偏移量，以查看是否消费了相应的消息。
另外，请不要犹豫，让我知道，如果这是正确的方式来处理用例，因为我在Kafka没有经验。我知道kafka不是设计成这样工作的（处理上面的用例），但是我必须坚持kafka。