It can be done with the consumer API. However, you're just going to end up
re-implementing what is already there in the streams DSL. It will be far
easier to use the Stream DSL join functionality to accomplish this. I've
never tried to do it with a simple consumer.
On Wed, Feb 16, 2022 at 6:45 PM
Hello All,
I've a GCP Dataproc cluster, and i'm running a Spark StructuredStreaming
job on this.
I'm trying to use KafkaProducer to push aggregated data into a Kafka
topic, however when i import KafkaProducer (from kafka import
KafkaProducer), it gives error
```
Traceback (most recent call last
