当我在日常工作中偶然发现这一点时，我可以在网上找到一些关于这一点的描述如下：
在kafka版本0.8.1.1中，消费者将其补偿提交给zookeeper。当存在大量偏移量（即，使用者计数*分区计数）时，zookeeper不能很好地伸缩（特别是对于写入）。幸运的是，kafka现在提供了一种理想的机制来存储消费补偿。消费者可以将他们的补偿写在一个持久的（复制的）和高度可用的主题上，从而在kafka中实现。使用者可以通过读取此主题来获取偏移量（尽管我们提供了内存中的偏移量缓存，以便更快地访问）。i、 例如，偏移提交是常规的生产者请求（这是廉价的），偏移获取是快速的内存查找。
Kafka的官方文档描述了该功能是如何工作的，以及如何将偏移从zookeeper迁移到Kafka。这个wiki提供了示例代码，演示如何使用新的基于kafka的偏移存储机制。

try {
        BlockingChannel channel = new BlockingChannel("localhost", 9092,
                BlockingChannel.UseDefaultBufferSize(),
                BlockingChannel.UseDefaultBufferSize(),
                5000 /* read timeout in millis */);
        channel.connect();
        final String MY_GROUP = "demoGroup";
        final String MY_CLIENTID = "demoClientId";
        int correlationId = 0;
        final TopicAndPartition testPartition0 = new TopicAndPartition("demoTopic", 0);
        final TopicAndPartition testPartition1 = new TopicAndPartition("demoTopic", 1);
        channel.send(new ConsumerMetadataRequest(MY_GROUP, ConsumerMetadataRequest.CurrentVersion(), correlationId++, MY_CLIENTID));
        ConsumerMetadataResponse metadataResponse = ConsumerMetadataResponse.readFrom(channel.receive().buffer());

        if (metadataResponse.errorCode() == ErrorMapping.NoError()) {
            Broker offsetManager = metadataResponse.coordinator();
            // if the coordinator is different, from the above channel's host then reconnect
            channel.disconnect();
            channel = new BlockingChannel(offsetManager.host(), offsetManager.port(),
                                          BlockingChannel.UseDefaultBufferSize(),
                                          BlockingChannel.UseDefaultBufferSize(),
                                          5000 /* read timeout in millis */);
            channel.connect();
        } else {
            // retry (after backoff)
        }
    }
    catch (IOException e) {
        // retry the query (after backoff)
    }

在kafka版本0.8.1.1中，消费者将其补偿提交给zookeeper。当存在大量偏移量（即，使用者计数*分区计数）时，zookeeper不能很好地伸缩（特别是对于写入）。幸运的是，kafka现在提供了一种理想的机制来存储消费补偿。消费者可以将他们的补偿写在一个持久的（复制的）和高度可用的主题上，从而在kafka中实现。使用者可以通过读取此主题来获取偏移量（尽管我们提供了内存中的偏移量缓存，以便更快地访问）。i、 例如，偏移提交是常规的生产者请求（这是廉价的），偏移获取是快速的内存查找。
Kafka的官方文档描述了该功能是如何工作的，以及如何将偏移从zookeeper迁移到Kafka。
其思想是，如果您需要所描述的功能，那么您需要将数据存储在rdbs、nosql数据库或elk堆栈中。一个好的模式将通过Kafka连接使用接收器连接器。kafka中的正常消息处理是通过consummer或流定义来完成的，这些流定义在事件发生时对事件做出React。在某些情况下，您当然可以寻求偏移量或时间戳，这是完全可能的。。。
在Kafka的最新版本中，偏移量不再保存在zookeeper中。所以zookeeper不参与场景处理的消费者。