Skip to content

Tag: apache-kafka

How can I create Kafka stream from Python?

How can I create a Kafka stream directly from Python? I know that I need to use GQLAlchemy but I don’t know the exact commands. Answer GQLAlchemy is a fully open-source Python library and Object Graph Mapper (OGM) – a link between graph database objects and Python objects. An Object Graph Mapper o…

Multi Topic Consumer Identify topic

I have a consumer that consumes from two topics with two different avro schemas. The number of topics can grow in the future, so unioning schemas to read from multiple topics is not scalable. How do I identify/extract which topic the message is from, without deserializing it with the avro schema? Wondering if…

Kafka consumer/producer with Python in WSL2 Ubuntu

This is a follow-up question from this thread. As per advised from the thread, the possible cause for why my Python code is not working is because I was to connect to a remote server in WSL2. And there could be unknown issues with WSL2 Ubuntu. So I am testing that hypothesis with the following two approaches …