我有一个场景,我有不同类型的消息从kafka producer中流式传输。
如果我不想针对不同的消息类型使用不同的主题,如何在spark-structured streaming消费者端处理它?How to identify which message is been received from Kafka topic?Please let me know how to handle this scenario at kafka co
您能提供一些关于使用Python使用Azure Service Bus流消息的建议吗?因为我发现Azure Service Bus没有spark结构化流源,所以在这种情况下,我可以使用提供的Python客户端读取Azure Service Bus消息,然后从Python客户端读取每个消息并将其写入Kafka主题,在这个Kafka主题上,我将应用spark结构化流编