Select Git revision
SlackKafkaProducer.py
Seok Won authored
this producer reads all messages from "#general", in every 5 seconds (this will cause ratelimited) and if messages contain a word "bug", it will automatically sends "USERNAME" and "MESSAGE" to Kafka consumer. And the consumer will leave a message in "#kafka" channel saying "USER found a bug ..."
SlackKafkaProducer.py 2.61 KiB