В моем приложении верблюда у меня есть простой маршрут, использующий одну тему кафки, задающий только несколько заголовков в простом процессоре и отправляющий обмен на другую тему кафки:
.from(kafka:startTopic).process(new HeaderEnrichter).to(kafka:endTopic)
Я используюверблюжья нить по умолчанию.Мои сообщения находятся между 1Kb и 3Kb .Для kafka я использую значения по умолчанию для потребителя (опрос) и производителя (пакетирование).Для 1 раздела и машины с 16 ГБ ОЗУ, я заметил, что только около 100 мсг / сек можно отправить в одну тему.
Я пытался увеличить максимум записей опроса и размер пакета , но это не увеличило пропускную способность.Мне интересно, на какие параметры / стратегии следует обратить внимание, чтобы увеличить пропускную способность?Я ожидал, что> 5000 / MSG должно быть возможно?