кафки по 40 партиций на топик. консумеры на всех партициях висят, но при этом сообщения из партиций не вычитывает.
по логам кафки или зукипера никаких проблем не вижу. Консумеры с двух нод по 20 на топик. реализация консумеров : org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener
Почему могут зависать консумеры?
Какая версия spring-kafka? ack делаешь вручную?
Обсуждают сегодня