Масштабирование потребителей с помощью расширений Axon - Kafka - PullRequest
Новая
       20

Масштабирование потребителей с помощью расширений Axon - Kafka

1 голос
/ 11 февраля 2020

Пожалуйста, помогите мне с рекомендациями по масштабированию проекции аксона, используя ниже startegys

  • Многопоточная группа потребителей
  • Обслуживание потребителей в горизонтальном масштабе

Получил ниже настройки

  1. Kafka topi c с двумя разделами: KAFKA_CREATE_TOPICS: "axon-events:2:1"
  2. Служба команд, которая генерирует события с конфигурацией: 
    command-processor:         
    mode: tracking         
    source: kafkaMessageSource
Процессор запросов со следующими конфигурациями: 
    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]

Если я Попробуйте запустить несколько экземпляров обработчика запросов (на двух отдельных портах), только один обработчик запросов активен одновременно.

...