如何使用spring cloud在kafka的两个服务实例中使用所有分区
背景是：
我想在收到kafka消息时触发websocket客户端。对于两个websocket服务器实例，这会产生一个问题，即kafka分区不必与服务于确切websocket客户端的服务器实例相关联。
Kafka主题中已经填充了具有多个分区的消息。我对重置偏移量和真正的“提交日志作为真相的来源”不感兴趣。对于这种情况，kafka只用于将触发器传递给web套接字客户端
我需要的：
我的意图是绕过同一个消费组的自然分区。我想在同一个组id的所有实例上接收来自所有分区的消息。所以我想要重复的。我在kafka之上使用Spring cloud。
共有1个答案
我想从相同组id的所有实例上的所有分区接收消息。
这是不可能的。您需要每个消费者实例的唯一组才能获取要使用的所有分区。
-
本文向大家介绍SpringCloud使用Feign实现服务调用，包括了SpringCloud使用Feign实现服务调用的使用技巧和注意事项，需要的朋友参考一下 Spring Cloud Feign简介 Spring Cloud Feign也是一个基础工具类，它整合了Spring Cloud Ribbon和Spring Cloud Hystrix，除了提供这两者的强大功能以外，它还提供了一种声明式的
-
本文向大家介绍Springcloud中的region和zone的使用实例，包括了Springcloud中的region和zone的使用实例的使用技巧和注意事项，需要的朋友参考一下 一、背景 用户量比较大或者用户地理位置分布范围很广的项目，一般都会有多个机房。这个时候如果上线springCloud服务的话，我们希望一个机房内的服务优先调用同一个机房内的服务 ，当同一个机房的服务不可用的时候，再去调用
-
这个例子的目的是向您展示如何构建一个预装Riak的docker镜象。 创建Dockerfile 创建一个空文件Dockerfile $ touch Dockerfile 接下来，定义你想要来建立你镜像的父镜像。我们将使用Ubuntu（tag：最新版），从Docker Hub中下载： # Riak # # VERSION 0.1.0 # Use the Ubuntu base ima
-
然后，我对一个方法使用了注释，该方法执行以下操作： 这不起作用。是事务性的，但是当调用方法时，没有正在进行的事务，并且我得到一个。 我打算尝试方法，但Javadoc声明这只用于本地事务，因此它似乎不符合我的需要。 我的下一步是尝试直接使用Kafka的Producer API，看看这种模式是否有效，但如果有人能告诉我知道我在浪费时间，Kafka不支持事务性地写多个主题，我会很感激。 我确实在Conf
-
问题内容： 使用KTable时，当实例/使用者数等于分区数时，Kafka流不允许实例从特定主题的多个分区中读取。我尝试使用GlobalKTable实现此目的，但问题是数据将被覆盖，也无法对其应用聚合。 假设我有一个名为“ data_in”的主题，具有3个分区（P1，P2，P3）。当我运行Kafka流应用程序的3个实例（I1，I2，I3）时，我希望每个实例都从“ data_in”的所有分区中读取数据
-
我们正在使用using通过将app ServiceLocator桥接到Jersey ServiceLocator中，将在一个ServiceLocator中创建的现有单例应用程序服务注入到Jersey RESTful Web服务中。 然而，存在于“外部”定位器中的单例并没有被使用--每个服务都是在注入到Jersey服务中时再次创建的。单例似乎只在ServiceLocator的范围内可见，即使它是桥接