Kafka为一个分区返回endOffset 15，但是最后一条可以从中消费的消息的偏移量是13，而不是我所期望的14，我想知道为什么。
Kafka的文献中写道
在默认的read_uncommitted隔离级别中，结束偏移量是高水位线（即，最后一个成功复制的消息的偏移量加1）。对于read_committed使用者，结束偏移量是最后稳定偏移量（LSO），它是高水位线和任何打开事务处理的最小偏移量中的最小值。
下面是kafkacat的输出，我使用kafkacat是因为它可以打印消息偏移量：

$ kafkacat -Ce -p0 -tTK -f'offset: %o key: %k\n'
offset: 0 key: 0108
offset: 1 key: 0253
offset: 4 key: 0278
offset: 5 key: 0198
offset: 8 key: 0278
offset: 9 key: 0210
offset: 10 key: 0253
offset: 11 key: 1058
offset: 12 key: 0141
offset: 13 key: 1141
% Reached end of topic TK [0] at offset 15: exiting

同样令人困惑的是--这很可能是相关的--偏移不是连续的，尽管我没有设置压缩等。
更多详情：

$ kafka-topics.sh --bootstrap-server localhost:9092 --topic TK --describe
Topic: TK       PartitionCount: 2       ReplicationFactor: 1    Configs: segment.bytes=1073741824
        Topic: TK       Partition: 0    Leader: 0       Replicas: 0     Isr: 0
        Topic: TK       Partition: 1    Leader: 0       Replicas: 0     Isr: 0

通过www.example.com打印密钥kafka-console-consumer.sh:

$ kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic TK \
  --offset earliest --partition 0 --timeout-ms 5000 \
  --property print.key=true --property print.value=false
0108
0253
0278
0198
0278
0210
0253
1058
0141
1141
[2021-09-15 10:54:06,556] ERROR Error processing message, terminating consumer process:  (kafka.tools.ConsoleConsumer$)
org.apache.kafka.common.errors.TimeoutException
Processed a total of 10 messages

注意：本主题的生成不涉及事务，并且 *）消耗是在read_uncommitted模式下完成的。

• ）实际上，processing.guarantee设置为exactly_once_beta，因此这相当于使用事务。
  更多信息事实证明，我可以用我的Streams应用可靠地重现这种情况（1. wipe Kafka/zookeeper data，2. recreate topics，3. run app），它的输出是显示这个问题的主题。同时，我将Streams应用精简为这种无操作拓扑，仍然可以重现它：

Topologies:
   Sub-topology: 0
    Source: KSTREAM-SOURCE-0000000000 (topics: [TK1])
      --> KSTREAM-SINK-0000000001
    Sink: KSTREAM-SINK-0000000001 (topic: TK)
      <-- KSTREAM-SOURCE-0000000000

News同时我已经将本地运行的Kafka broker（2.5.0）替换为Docker容器中运行的broker（wurstmeister/kafka：2.13-2.6.0）。问题仍然存在。

该应用程序使用的是版本号为6.0.1-ccs的Kafka库，对应于2.6.0。