消费者行为 - 腾讯云开发者社区

我们有消息层的需求，我们希望消息的顺序被保留，直到它被消费者消费。我们正在探索同样的Kafka。我在想，如果我们能以某种方式确保特定的生产者(具有特定的键值属性)将其消息发布到主题t1的特定分区p1中，并且我们可以确保消费者从相同的分区p1中获取消息。这会达到我们的目的。 --producer-property <producer_prop> A mechanism to pass user-defined properties in the form key=value to

浏览 0提问于2017-02-02得票数 2

1回答

卡夫卡消费者在CommitFailedException之后不停地浏览一堆信息

、

我正在运行一个多线程卡夫卡091消费者新。我生成client.id的方式是使用“使用者在”+ "AtomicInt“+”进程PID“上运行的主机名的组合。当我必须停止使用者并重新启动时，我遇到了问题。使用者一直在尝试处理上一次运行中没有使用的偏移量(其中大约有100次)。但这条信息一直在失败。 2016-10-21 14:22:55,293 [pool-3-thread-6] INFO o.a.k.c.c.i.AbstractCoordinator : Marking the coordinator 2147483647 dead. 2016-10-21 14:22:55,

浏览 1提问于2016-10-21得票数 0

回答已采纳

2回答

Kafka SimpleConsumer (低级消费者)用例/优势

、

只有SimpleConsumer API才能控制每个使用者从哪个分区检索数据，据说它具有更好的偏移管理。有人能详细解释一下，在什么情况下，这种精细的谷物控制是在使用不太复杂的高级消费者时需要的。谢谢。

浏览 4提问于2016-07-08得票数 2

回答已采纳

2回答

java PECS List<？超级T> dest和List<T> dest的区别？

public static <T> void copy1(List<? extends T> src, List<? super T> dest) { for (int i = 0; i < src.size(); i++) { dest.add(src.get(i)); } } public static <T> void copy2(List<? extends T> src, List<T> dest) { for (int i = 0; i < src.size

浏览 0提问于2020-03-12得票数 1

2回答

Kafka多分区排序

、、、

我知道在Kafka中不可能对多个分区进行排序，并且分区排序只保证组内的单个使用者(对于单个分区)。然而，在Kafka Streams 0.10中，现在可以实现这一点吗？如果我们使用时间戳特性，使得每个分区中的每个消息都保持顺序，那么在消费者端，假设使用Kafka Streams 0.10，现在这是可能的吗？假设我们收到了所有消息，我们可以不根据消耗的时间戳对所有分区进行排序，然后将它们转发到单独的主题进行消费吗？目前，我需要保持排序，但这意味着只有一个分区和一个消费者线程。我想将其更改为多个分区，以增加并行性，但却以某种方式“使它们有序”。有什么想法吗？谢谢。

浏览 0提问于2016-09-19得票数 8