java.lang.IllegalArgumentException: Magic v1 does not support record headers это значит кафка старая и не поддерживает хидеры надо просто обновиться. for debug purpose: https://github.com/awaitility/awaitility https://gist.github.com/itzg/e14fe6965175b65e14881e7c5264c707 kafka: по мотивам: https://dzone.com/articles/running-apache-kafka-on-windows-os server.properties: кто бы мог подумать что ему не все равно - log.dirs=C:/soft/kafka_2.12-0.10.2.0/tmp/logs так работает а так нет log.dirs=C:\soft\kafka_2.12-0.10.2.0\tmp\logs C:\soft\kafka_2.12-0.10.2.0\bin\windows>kafka-topics.bat --delete --topic s1p.topic --zookeeper localhost:2181 Topic s1p.topic is already marked for deletion. kafka-topics --list --zookeeper localhost:2181 s1p.topic - marked for deletion но когда это фактически случится никто не знает..... и это настораживает! тут надо что - а тут надо копать! Иван Федрыч КАПАЙ делает работу)! src: https://zookeeper.apache.org...