а) Вы можете попробовать извлечь все тематические сообщения в файл
kafka-console-consumer --bootstrap-server localhost:9092 --topic <TOPIC> --from-beginning > singlefile.txt
Вы также можете добавить --property print.key=true, чтобы включить ключ сообщения
Вы можете использовать вывод файла для вывода данных в kafka.
б)
Вы можете получить разделы раздела, конфигурации и статус синхронизации с помощью этой команды
kafka-topics --describe --zookeeper localhost:2181 --topic <TOPIC>
Вы можете получить настройки темы с помощью этой команды
kafka-configs --zookeeper localhost:2181 --describe --entity-type topics --entity-name <TOPIC>
Вы можете использовать add для каждой команды и экспортировать их в файловую систему.
> simplefile.txt