偏移和分区-Kafka接收器处理器
我们正在使用kafka拓扑转发向kafka主题发送记录。
我们之前使用了一个单独的生产者来发布消息，我们能够获取消息的偏移量和分区。现在我们想用上下文替换它。向前地
如何使用上下文获取Kafka接收器处理器发送的记录的偏移量和分区。向前地
共有1个答案
将消息发布到制作人中的主题。type=sync模式。当您调用send（）方法时，它将返回您正在查找的所有详细信息。
-
我想重置AerospikeSink Kafka Connector偏移量，我首先删除连接器消费组（）偏移量，然后重新创建它。当我使用策略重新创建时，它以正确的偏移量重新创建，但是然后，当任务状态从更改为任务时，它会从连接器的前一个实例到达的点继续处理，这会阻止从一开始就读取来自kafka的所有消息（我正在尝试再次读取来自kafka的所有消息）。 注意：使用新名称创建新连接器并不能解决问题。 使用任
-
我需要打印/记录/存储处理消息的kafka分区和偏移量。我如何才能做到这一点？我使用StreamBridge从制作人那里发送消息，还使用功能性spring kafka streams方法
-
我有一个Kafka接收器任务，通过方法收听Kafka主题 但我不想自动提交偏移量，因为一旦从Kafka取出记录，我就有一些处理逻辑 从Kafka获取记录后，如果处理成功，则只有我想提交偏移量，否则它应该再次从同一偏移量读取。 我可以在Kafka consumer中看到方法，但在中找不到替代方法。
-
我有一个由5个分区组成的主题如下： 似乎分区的偏移量非常接近其余分区的偏移量之和。我不知道如何以及为什么。
-
在我的例子中，我们有auto.commit.enable=false，以便在处理消息后将offset提交给Zookeeper。如果处理失败，那么offset将不会被提交，我们应该尝试在某个配置的时间内再次处理相同的消息，从zookeeper的offset开始。但它不起作用，因为，我假设，Apache Kafka客户端在内存中保留了偏移量。 我发现kafka.consumer.consumerite
-
在我的网站中，用户A创建了一个从上午9:00开始的事件。我将该时间转换为GMT，这样，如果用户B在两小时前的不同时区看到该事件，它可以转换为用户B的时区，并显示该事件在11:00AM开始。 我唯一的想法是，当我得到如下所示的时区偏移量时，我是否应该总是将日期设置为一月，以便无论实际月份如何，我总是得到相同的时区偏移量？或者有没有更好的方法来处理这件事？