Kafka上次消息投票结果为0条消息

Question

我有一个Kafka主题（1.0.0），只有一个分区。消费者被封装在EAR中，当部署到Wildfly 10时，最后一条消息的轮询始终返回0条消息。虽然主题不是空的。

java prettyprint-override">final TopicPartition tp = new TopicPartition(topic, 0);

final Long beginningOffset = consumer.beginningOffsets(Collections.singleton(tp)).get(tp);
final Long endOffset = consumer.endOffsets(Collections.singleton(tp)).get(tp);

consumer.assign(Collections.singleton(tp));
consumer.seek(tp, endOffset - 1); 

当我做民意测验时，我得到0条记录。尽管日志记录显示：

Consumer is now at position 377408 while Topic begin is 0 and end is 377409

当我更改为-2时，如：

consumer.seek(tp, endOffset - 2);

我确实收到一条消息：

 Consumer is now at position 377407 while Topic begin is 0 and end is 377409

当然，这不是正确的记录，消息377408在哪里？

尝试了许多方法来寻求结束等，但它从来没有工作。

这是我的消费者配置：

Properties properties = new Properties();
properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, Configuration.KAFKA_SERVERS.getAsString());
properties.put(ConsumerConfig.GROUP_ID_CONFIG, GROUP_ID);
properties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, LongDeserializer.class);
properties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
properties.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");
properties.put(ConsumerConfig.ISOLATION_LEVEL_CONFIG, "read_committed");

注意：我尝试了read\u uncommitted和read\u committed，两者的结果相同。

Answer 1

正如Javadoc中提到的，这是因为endOffsets（）返回：

最后一条成功复制的消息的偏移量加一

这实际上是下一条消息将获得的偏移量。

这就是为什么搜索endOffset-1不返回任何信息，而搜索endOffset-2只返回最后一条消息。

我同意这可能不是最直观的行为，但这就是它目前的工作方式！