通常来讲,消息模型可以分为两种, 队列和发布-订阅式。 队列的处理方式是 一组消费者从服务器读取消息,一条消息只有其中的一个消费者来处理。在发布-订阅模型中,消息被广播给所有的消费者,接收到消息的消费者都可以处理此消息。Kafka 为这两种模型提供了单一的消费者抽象模型: 消费者组 ( consumer group )。 消费者用一个消费者组名标记自己。 一个发布在 Topic 上消息被分发给此消费者组中的一个消费者。 假如所有的消费者都在一个组中,那么这就变成了 queue 模型。 假如所有的消费者都在不同的组中,那么就完全变成了发布-订阅模型。 更通用的, 我们可以创建一些消费者组作为逻辑上的订阅者。每个组包含数目不等的消费者, 一个组内多个消费者可以用来扩展性能和容错。
作者:半兽人
链接:
https://www.orchome.com/5来源:OrcHome
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。
找到原因了伙计们,即以上所述,基础鸭。
更改前配置:
spring:
kafka:
consumer:
group-id: websocket
更改后配置:
spring:
kafka:
consumer:
group-id: ${spring.cloud.client.hostname}:${server.port}:websocket