Kafka 1.0重置偏移量不会将所有分区重置为0
将kafka consumer offset重置为“最早”时，它会保留一些带有偏移量的分区
$kafka-consumer-groups.sh--bootstra-server127.0.0.1:9092--group Group1--topic1--reset-offset--to-最早执行
显示：
TOPIC PARTITION NEW-OFFSET
topic1 4 0
topic1 1 6153734
topic1 3 0
topic1 2 0
topic1 0 0
为什么分区1也没有0？
共有1个答案
问题是最早的偏移量实际上是6153734
找到它时使用了--重置偏移量--偏移0
输出
WARN New offset (0) is lower than earliest offset. Value will be set to 6153734 (kafka.admin.ConsumerGroupCommand$)
-
我有一个Spring Cloud Stream Kafka Stream应用程序，它读取主题（事件）并执行一个简单的处理： 该应用程序使用来自Confluent Cloud的Kafka环境，带有6个分区的事件主题。完整的配置是： 首先，它显示还原使用者客户端的创建。自动偏移复位无: > 配置了两个消费者的原因是什么？ 为什么第二个函数具有，而我没有显式配置它，而且Kafka的默认值是最新的？ 我已
-
简而言之，我想从一开始就对Kafka的数据重新运行Flink管道。 Flink0.10.2，Kafka0.8.2。 我在Kafka中有一个保留2小时的推文主题，以及Flink中的一个管道，该管道以每10秒5分钟的滑动窗口计算推文。 如果我中断管道并重新运行它，我希望它重新读取旧推文，从而发出价值5分钟的推文计数。相反，它似乎从新到达的推文重新开始，因此需要5分钟才能计数为“处于状态”。 我已经尝试
-
我对Kafka0.11.0.0有意见 在Kafka0.10.2.1中我对此没有任何问题。我只在0.11.0.0版本中遇到这个问题。 我的使用者将auto.offset.reset设置为最早，而auto commit设置为false，因为我是手动提交的。Kafka数据存储在具有必要权限的非TMP目录中。broker配置的其余部分为默认配置。 我需要0.11.0.0版本的事务。我不知道问题出在哪里。这
-
我遇到的问题是，当Kafka和Flink作业重新启动时，Flink Kafka消费者偏移量会重置为0，因此即使我启用了检查点并且我在Flink作业中启用了精确一次语义学，数据也会被重新处理。 这是我的环境详细信息 < li >在Kubernetes下奔跑 < li>Kafka源主题有10个分区，没有复制。 < li >Kafka有三个经纪人。 < li>Flink checkpointing启用了
-
我正在使用spring-cloud-kafka绑定器将数据读取到KStream。在阅读其中一个主题的数据时，我需要从头开始阅读。 我尝试设置kafka偏移重置和启动偏移属性。但是，找不到任何参考。 你能帮我提供任何示例application.yaml来重置偏移量吗？这样我就可以从一开始就使用主题中的消息。 添加我使用过的应用程序：
-
我正在尝试将Twitter日期时间转换为本地ISO字符串（用于prettyDate），现在为2天。我只是没弄准当地时间.. im使用以下功能： 在newdate中，一切正常，但toISOString（）将它再次返回到原始时间。有谁能帮我从Twitterdate格式为：Thu,31 May 2012 08:33:41+0000的iso中获取当地时间吗