Spring的Kafka--从一个话题看多个消费者的阅读

Question

我正在使用spring boot构建一个web应用程序，现在我需要接收实时通知。我正计划使用apache kafka作为这方面的消息代理。要求用户具有不同的角色，并且根据角色，他们应该接收其他用户正在执行的操作的通知。
我设置了一个生产者和消费者，作为消费者，我可以接收发布到一个主题的信息，比如说topic1。
我遇到的问题是，我可以让多个用户收听同一个主题，而每个用户都应该得到发布到该主题的消息。我理解，对于这个需求，我们需要为每个kafkalistener设置不同的group.id，以便每个消费者都能得到消息。
但是，当用户登录时，如何创建具有不同组id的kafkalistener？希望有人能在这方面提供一些指导？谢谢你

Answer 1

每次只需创建一个新的KafkaMessageListenerContainer并根据需要启动/停止它。

您可以使用引导自动配置的ConcurrentKafKalistenerContainerFactory来创建容器。只需设置groupid容器属性，使其唯一。

编辑

@SpringBootApplication
public class So60150686Application {

    public static void main(String[] args) {
        SpringApplication.run(So60150686Application.class, args);
    }

    @Bean
    public ApplicationRunner runner(KafkaTemplate<String, String> template) {
        return args -> {
            template.send("so60150686", "foo");
        };
    }

    @Bean
    public NewTopic topic() {
        return TopicBuilder.name("so60150686").partitions(1).replicas(1).build();
    }

}

@RestController
class Web {

    private final ConcurrentKafkaListenerContainerFactory<String, String> factory;

    public Web(ConcurrentKafkaListenerContainerFactory<String, String> factory) {
        this.factory = factory;
    }

    @GetMapping(path="/foo/{group}")
    public String foo(@PathVariable String group) {
        ConcurrentMessageListenerContainer<String, String> container = factory.createContainer("so60150686");
        container.getContainerProperties().setGroupId(group);
        container.getContainerProperties().setMessageListener(new MessageListener<String, String>() {

            @Override
            public void onMessage(ConsumerRecord<String, String> record) {
                System.out.println(record);
            }

        });
        container.start();
        return "ok";
    }

}

spring.kafka.consumer.auto-offset-reset=earliest

$ http localhost:8080/foo/bar
HTTP/1.1 200 
Connection: keep-alive
Content-Length: 2
Content-Type: text/plain;charset=UTF-8
Date: Mon, 10 Feb 2020 19:42:02 GMT
Keep-Alive: timeout=60

ok