Sequence that can retrieve data from Kafka topic and show the result on 'output'.


  • Name: @scramjet/python-kafka-consumer
  • Version: 0.23.0
  • Language: python
  • Author: Tatarinho
  • Tags: advanced,Kafka,message queue,Big Data/BI,Data Consumer

If you are looking for more advanced demo of usage, please check README


❗ Remember to setup transform-hub locally or use the platform's environment for the sequence deployment.

First, build kafka-consumer sample

# go to 'kafka-consumer' directory cd python/kafka-consumer # build npm run build

If you run this sample on Self Hosted Hub, please start it with process adapter option:

DEVELOPMENT=1 sth --runtime-adapter=process

The second terminal

si seq deploy kafka-consumer/dist --args [{\"topic\":\"TOPIC\"},{\"server\":\"\"}]

Please note, that you need to deploy consumer sample with two args. One is topic, which is Kafka Topic name, from which you want to consume data. Second argument is address of your Kafka.

If you have data on specified topic, you should be able to see information on STH terminal. It should look similar to:

Topic name=TOPIC, Message=b'test message'