消费同样的Kafka话题，如何复制微服务？
应用程序通过在服务的独特使用者主题中生成消息来查询服务。
查询消息由报头和有效载荷组成。除其他外，头包含应该在其中产生响应的主题信息。
服务生成响应并将其发送到完成请求周期的应用程序使用者主题。
考虑到响应必须始终到达负责请求的应用程序实例，在主题名称和分区复制方面，什么是最好的方法？
共有1个答案
我不打算在这里讨论分区，因为这取决于您自己对排序的要求，我无法真正推断出足够的信息来对其进行任何有根据的猜测。
关于横向扩展您的消费者/生产者，我希望能提供帮助。
简单的方法：你提到你的消息上有一个标题，我会包括额外的元数据，比如“发送者”。将所有消息发布到单个主题，但让每个服务注册为使用者组-使用服务名称。
-
我看了Kafka的文件，还不知道如何消费一个话题平行？ 假设：我有一个像“发生了一些事情”这样的话题（不要拆分这个话题），我有很多想消费它的客户。那么该怎么办，让多个客户并行消费呢？我应该使用分区和客户群吗？
-
按照此处提到的解决方案，kafka-mire-maker-fasting-to-复制-消费者-偏移-主题。我能够跨DC1（Live Kafka集群）和DC2（Backup Kafka集群）集群启动镜像制作器而没有任何错误。 看起来它还能够从DC1集群跨DC2集群同步主题。 问题 如果我关闭 DC1 的使用者并将同一使用者（同一group_id）指向 DC2，即使镜像制造商能够同步本主题和分区的偏移
-
我们有一个服务器，负责处理消息的生成和消费。我们有4台笔记本电脑，所有带有confluent的Mac都运行相同的命令行。。。 /kafka avro控制台使用者--从一开始--引导服务器0.0.0.0:9092,0.0.0.0:9092--主题主题名称--属性schema.registry.url=http://0.0.0.0:8081 4台笔记本电脑中有3台没有问题使用这些消息，但是第四台不会。
-
本文向大家介绍Kafka 的消费者如何消费数据相关面试题，主要包含被问及Kafka 的消费者如何消费数据时的应答技巧和注意事项，需要的朋友参考一下 消费者每次消费数据的时候，消费者都会记录消费的物理偏移量（offset）的位置 等到下次消费时，他会接着上次位置继续消费
-
我的问题与单个消费者从多个话题消费有关。假设所有主题都加载了1M个记录，一个使用者必须处理这些记录。它将按照什么顺序从主题中读取（我的意思是首先读取哪个主题/分区，等等） Kafka内部资料的任何链接会有帮助吗？
-
我有一个spring boot项目，我是spring-kafka来连接底层的kafka事件枢纽。 我不得不在同一节消费者课上听2个不同的话题。我有两种方法可以这样做。 一个是要有两个这样的Kafka听众： 另一种方法是在同一个kafkaListener中有两个主题，如下所示 ===================edit===============application.yml中的Kafka属性