apache-kafka - 使用 Axon 扩展消费者 - Kafka 扩展

Question

请帮助我使用以下 startegys 扩展轴突投影的指南

• 多线程消费者组
• 消费者服务水平扩展

得到以下设置

1. 具有两个分区的 Kafka 主题：KAFKA_CREATE_TOPICS: "axon-events:2:1"
2. 使用配置生成事件的命令服务：

    command-processor:         
    mode: tracking         
    source: kafkaMessageSource

3. 具有以下配置的查询处理器：

    mode: tracking                  
    source: kafkaMessageSource         
    threadCount: 2                 
    initialSegmentCount: 4

当我运行查询处理器时，我收到以下警告：

[Consumer clientId=consumer-1, groupId=query-group] 1 partitions have leader brokers without a matching listener, including [axon-events-0]

如果我尝试运行多个查询处理器实例（在两个单独的端口上），一次只有一个查询处理器处于活动状态。

标签： apache-kafkaaxon