卡夫卡消费者不使用Spark消费重新处理的数据我们使用pyspark应用程序来处理Kafka中源主题中的一些数据,并将处理后的数据写入单独的主题中。我们还有另一个python应用程序,它使用Kafka python来使用处理过的主题。第一次运行时 ...2024-06-10 已阅读: n次