Почему в теме кафки нет выходных данных, когда я использую wirteStream () для потокового воспроизведения?Версия: spark2.4.3

Question

Я хочу использовать приемник kafka в документации по потоковой передаче для записи моих данных в kafka, но почему нет вывода в теме kafka, пока есть журнал запросов?

Я использую javaКод, упомянутый в документации, версия искры 2.4.3

query = result
        .writeStream()
        .outputMode(outputmode)
        .format("kafka")
        .option("kafka.bootstrap.servers", kafkaMap.get("kafka.bootstrap.servers").toString())
        .option("topic", kafkaMap.get("topic").toString())
        .option("checkpointLocation", "path/to/HDFS/dir")
        .trigger(Trigger.ProcessingTime(triggerTime))
        .start();

. Источник входного сигнала - гнездо.В других тестовых случаях вход работает хорошо.А данные - это просто строка

Я не знаю, почему в теме кафки нет вывода, когда я запускаю потребителя.Когда я использую консольный приемник, вывод выглядит так: