Kafka消费者是顺序的还是平行的？
在我的应用程序中，有多个企业。每个企业登录并做一些动作，如上传数据，然后Kafka生产者采取的数据，并发送到主题。另一方面，Kafka消费者使用来自主题的数据并执行业务逻辑。并保存到数据库中。在这种情况下，当单个企业登录时，一切都很完美。但当多个企业登录时，则Kafka依次消费。也就是说，我如何使过程并行？在多个客户端请求上。提前谢了。
共有1个答案
如果该主题只有一个分区，那么它在使用者端是连续的。一个分区的多个生产者不能保证订购。
消费者和生产者将对消息进行批处理，并以块的形式处理它们。
另一方面，Kafka消费者使用来自主题的数据并执行业务逻辑。并保存到数据库中。
我建议不要使用普通消费者。请研究Kafka Connect，看看是否支持您的数据库
-
当一个新的消费者/borker被添加或下降时，Kafka会触发一个再平衡操作。Kafka是在重新平衡封锁行动。Kafka的消费者是不是在一个再平衡操作正在进行的时候就被封锁了？
-
本文向大家介绍什么是kafka消费者组？相关面试题，主要包含被问及什么是kafka消费者组？时的应答技巧和注意事项，需要的朋友参考一下 答：消费者组的概念是Apache Kafka独有的。基本上，每个Kafka消费群体都由一个或多个共同消费一组订阅主题的消费者组成。
-
在消费者重新平衡期间如何确保消息排序。假设最初我们有四个分区:p1、p2、p3、p4和两个消费者c1和c2(在同一组中)。因此每个消费者得到两个分区，例如c1 : p1，p2和c2 : p3，p4。 现在添加了新的消费者，比如c3和c4，重新平衡发生，这样每个消费者都有一个分区，比如c1： p1、c2： p2、c3： p3、c4： p4。 在此期间，消费者c1可能正在处理来自分区p2的消息(在重新
-
我正在用java编写一个简单的Kafka使用者，它被配置为读取多个主题。目前，让我们假设两个主题(topic1和Topic2)，并为两个主题设置一个分区。 Kafka用户从topic1和Topic2读取的顺序是什么。如果这两个主题都有，假设已经发布了100条消息。 使用者首先从topic1读取所有消息，然后再从topic2读取？ 用户按时间顺序阅读，将来自两个主题的消息混合在一起？ 我看了Kafk
-
是否有一种方法以编程方式访问和打印使用者滞后偏移，或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视，我应该在上面添加哪些语句来得到滞后偏移值？
-
Flink kafka消费者有两种类型的消费者，例如： 这两个消费者层次结构扩展了相同的类。我想知道维护编号类背后的设计决策是什么？我们什么时候应该使用其中一种？ 我注意到带有数字后缀的类有更多的特性（例如ratelimiting）。 https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka