apache-kafka - 如何编写一个kafka消费者来消费一个sqoop命令？

Question

我有从休息服务生成的这个 sqoop 命令，我希望 kafka 消费者使用这个 sqoop 命令。

我对卡夫卡很陌生，需要帮助。