Kafka, Kafka Consumer, Kafka Producer, Confluent Kafka, Streaming.
consumer_characteristics = { 'group.id': 'taxirides.csv.consumer', 'auto.offset.reset': "earliest" } props = {**CONFLUENT_CLOUD_CONFIG, **consumer_characteristics} simple_consumer = SimpleConsumer(props=props) simple_consumer.consume(topics=[TOPIC]) The SimpleConsumer class is a thin wrapper around