¿Cómo implementar el mecanismo de comunicación entre thinkphp, kafka, hbase y spark?

Spark tiene su propio conector Kafka para leer datos de Kafka. Desde Spark hasta Hbase, muchas personas simplemente usan el operador foreach para escribir datos.