我正在尝试重置kafka主题的特定分区的偏移量，但我没有找到任何命令。kafka-consumer-groups.sh -- bootstap-server localhost:1111 -- command-config <file> -- group<grou
浏览 7提问于2019-02-27得票数 6
回答已采纳
我的kafka主题共有10条记录/消息和2个分区，每个分区有5条消息。我的使用者组有2个消费者，每个使用者已经分别从他们分配的分区中读取了5条消息。现在，我希望从开始/开始重新处理/读取来自我的主题的消息(偏移量0)。./kafka-consumer-groups.sh --group cg1 --reset-offsets --
浏览 3提问于2019-06-27得票数 4
我正在开发Kafka 0.9。我想知道是否有任何方法可以通过知道分区和偏移量从主题中检索已经处理过的消息。例如，消费者当前正在使用分区1和偏移量10处的消息，而我希望获取相同分区和偏移量5处的消息。我能想到的一种方法是将偏移量重置为5，并使用一条消息。但是poll()方法只能返回一批消息。因此，我不得不接受第一条消息，而忽略其他消息。处理完消息后，将偏移量重置回原处。
我想这会起作用的。
浏览 0提问于2016-04-06得票数 2
我希望将所有分区的偏移量重置为特定值.我看到kafka- CSV groups.sh. in提供了CSV文件中定义的值从文件重置偏移的选项。
有谁能分享这个csv文件的内容/格式以及它的示例命令？/kafka_2.12-2.1.1/bin/kafka-consumer-groups.sh --bootstrap-server ${KAFKA_BROKER} --group ${GROUP_NAME
浏览 1提问于2019-04-02得票数 10
回答已采纳
1回答
我在我的代码中使用了auto.offset.reset=earliest，并在以下代码的帮助下在kafka中使用了offset commit。我正在QA中测试这段代码，所以我想将偏移量重置为开始，但看起来最早的时间没有工作，它没有读取新消息，主题中也没有新消息。为了测试的目的，我想从头开始阅读消息。
浏览 1提问于2018-12-07得票数 0
使用kafka-python消费kafka，seek方法重置的本地偏移量会提交给kafka吗？我正在研究获取双中心机房Kafka集群的rpo索引的解决方案。使用kafka-python获取Kafka集群的最大时间戳，取两个机房的Kafka集群的最大时间戳之差。使用seek()将偏移量重置为分区的最大偏移量-1，然后使用poll()获取最新的消息，但该消息无法在循环
浏览 8提问于2021-05-20得票数 0
我有N个org.springframework.kafka.listener.ConcurrentMessageListenerContainer和N个MessageListeners在听一个主题的N个分区有时，应用程序需要在与上次提交的偏移量不同的偏移量处启动。我将监听器设置为ConsumerSeekAware，并使用registerSeekCallback()。只有在应用程序启动时才需要重置到不同的偏移量，而不是在运行时才需要重置，因此我不需要存储registerS
浏览 2提问于2017-12-06得票数 0
回答已采纳
1回答
我有一个主题“橙子”，其中有10个分区，1个消费者组中的2个消费者。我使用的是Spring Kafka。 由于某些原因，我需要不时地重新读取数据，我需要重置偏移量。这很好用，因为我在日志中看到来自Kafka客户端API (2.3.1)的消息： 正在重置分区oranges-X to offset 0的偏移量。所有分区都会发生这种情况。然而，实际上只有最后一个分区被重置(9)，如果我幸运的话，有时第二个
浏览 544提问于2020-06-19得票数 0
我试图将其中一个偏移量重置为1，但得到的消息是偏移量(1)低于主题分区的最早偏移量。➜ local-kafka_2.12-2.0.0 bin/kafka-consumer-groups.sh --bootstrap-server myserver:1025 --group mygroupNEW-OFFSET当我尝试不同的分区时，我会得到相同的消息：
➜
浏览 0提问于2019-02-01得票数 1
背景是：Kafka主题已经填充了多个分区的消息。我对重置偏移量和真正的“提交日志作为真相的来源”不感兴趣。在这种情况下，kafka仅用于将触发器传递给web套接字客户端我的意图是绕过具有相同消费者组的自然分区。我希望从具有相同
浏览 2提问于2020-01-31得票数 1
1回答
我在/var/lib/kafka中使用持久性卷我有一个主题，使用4个分区
我注意到，一旦有1个kafka节点被重新启动，偏移量就被重置为0。是否有任何原因需要重设偏移量？
浏览 3提问于2022-09-20得票数 0
回答已采纳
当将kafka消费者补偿重置为最早时，它会保留一些偏移量大于0的分区。$ kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group group1 --topic topic1 --reset-offsets6153734topic1 2 0为什么分区</em
浏览 0提问于2018-04-27得票数 0
回答已采纳
我有一个用例，我必须从一个主题消费并发布到另一个主题。如果任何事情都失败了，那么实际上在这些主题中不应该有任何改变。
浏览 3提问于2017-12-19得票数 0
1回答
首先，是kafka-consumer-group.sh脚本的输出。我得到了一些奇怪的输出，虽然它们似乎与特定的组/主题/分区相连接，但实际上并没有告诉我特定的使用者在哪里：
为什么当我可以直接查询Kafka的API时，某些当前的偏移量(第3列)和滞后(
浏览 1提问于2017-10-02得票数 0
回答已采纳
1回答
我正在寻找一些关于使用Spring 3.x / Kafka绑定器实现的Kafka主题的回放消息策略的指导-一般来说，关于消息回放的最佳实践是什么。谢谢您抽时间见我。
浏览 1提问于2020-08-18得票数 1
我一直在使用kafka主题的事件，在我的应用程序中处理同样的事件已经有一段时间了。该主题有20个分区，我将kafka并发设置为10，因为我使用来自kafka主题的事件和我的应用程序的2个副本。我将提交模式设置为手动立即，因此，一旦应用程序确保事件得到处理，我希望提交分区偏移量。一切都很好，直到卡夫卡服务器的一个或多个节点被关闭并重新启动的一天。我们使用卡夫卡经纪人的3个节点。由于我使用手动提交调用确认(我使用的是spring + kafka技术栈)，因此一旦成功地对特定
浏览 9提问于2021-01-30得票数 2
启用调试日志的行为如下：它清楚地显示使用者没有先前的偏移量，并且突然获取分区偏移量，使用者使用该偏移量并设置其新偏移量(请注意:先前从主题读取了36387条消息，因此在下面的日志中读取了编号)
将2016-12-22T16:45:13,544org.apache.kafka.clie
浏览 6提问于2016-12-23得票数 0
回答已采纳
我的kafka接收器连接器读取多个主题(配置有10个任务)，并处理来自所有主题的300多条记录。基于在每个记录中保存的信息，连接器可以执行某些操作。下面是触发器记录中键:值对的示例：读取此记录后，我将需要将每个分区中的主题“my 1”的偏移量重置为0。传递给onPartitionsAssigned方法的“分区”是动态分配的分区，这意味着这些分区只是整个分区集的子
浏览 1提问于2019-05-01得票数 6
回答已采纳
我在AWS MSK (2.3.1 (Commit:18a913733fb71c01))上尝试重置我的消费者组的偏移量时遇到问题。我尝试了kafka-consumer-group.sh，并尝试将主题分区偏移量重置为6200，结果也显示NEW_OFFSET为6200。但当我描述使用者组偏移量时，它仍然可以看到该特定分区仍然使用旧偏移量。下面是我的使用者组的当前状态，您可以从下面看到分区0的当前偏移量是4
浏览 1提问于2021-05-03得票数 1
3回答
我想构建一个API来修改它的偏移量。因此，当使用偏移量调用端点时，我必须更改使用者组的偏移量。我使用的是SpringBoot，消费者是用SpringBoot构建的。提前谢谢。
浏览 4提问于2021-04-16得票数 2
回答已采纳
云服务器
ICP备案
云直播
腾讯会议
对象存储
腾讯云开发者
