Вопрос по Kafka Engine (version
21.2.2.8). Пытаемся ускорить импорт из кафки, но не можем добиться больше 500 сообщений в секунду. Как понять в чем проблема и куда смотреть? Пробовали различные комбинации с kafka settings, создавали параллельно 3 консьюмера (отдельными таблицами с общей группой) так же игрались с kafka_num_consumers, но ничего не помогает.
Топик на три партиции, размер сообщения ~1.5кб, сейчас методом проб и ошибок вышли на такие значения, kafka_num_consumers = 3, kafka_max_block_size = 2000000, kafka_commit_every_batch = 1, kafka_thread_per_consumer = 1
Куда копать, что еще попробовать?