У меня есть 3-х узловая настройка кластера кафки. Я использую apache spark (потребитель) для чтения сообщений от брокера kafka. Каждый топи c имеет 6 разделов. все работало нормально. когда журналы поступают из apache Nifi в очередь kafka, потребитель Spark может плавно читать сообщения в смещениях, но в случае потребителя cra sh потребитель Spark не сможет читать оставшиеся сообщения от Kafka.
я читаю последние смещения от брокеров kafka моему потребителю.
Я использую kafka 2.11
Заранее спасибо.
Прашант