From 3e4ccc656baf332beca90f2050e13dd5112d776d Mon Sep 17 00:00:00 2001 From: kemalcanbora Date: Thu, 28 Mar 2019 21:22:28 +0300 Subject: [PATCH 1/2] kafka producer and consumer example for Google Fire --- examples/kafka/__init__.py | 0 examples/kafka/kafka.py | 25 +++++++++++++++++++++++++ 2 files changed, 25 insertions(+) create mode 100644 examples/kafka/__init__.py create mode 100644 examples/kafka/kafka.py diff --git a/examples/kafka/__init__.py b/examples/kafka/__init__.py new file mode 100644 index 00000000..e69de29b diff --git a/examples/kafka/kafka.py b/examples/kafka/kafka.py new file mode 100644 index 00000000..6f52b682 --- /dev/null +++ b/examples/kafka/kafka.py @@ -0,0 +1,25 @@ +import fire +from kafka import KafkaProducer +from kafka import KafkaConsumer + + +class KafkaFireExample: + def __init__(self): + self.producer = KafkaProducer(bootstrap_servers='localhost:9092') + + def kafka_producer(self, topic_name='Hello Topic'): + while True: + self.producer.send(topic_name, b'Hello, World!') + + def kafka_consumer(self, topic_name='Hello Topic'): + consumer = KafkaConsumer(topic_name) + for message in consumer: + return message + + +def main(): + fire.Fire(KafkaFireExample) + + +if __name__ == '__main__': + main() From b3e390a1ed7012797e7d59081ae352a9e4ba2f56 Mon Sep 17 00:00:00 2001 From: kemalcanbora Date: Fri, 29 Mar 2019 10:55:36 +0300 Subject: [PATCH 2/2] kafka producer and consumer example for Google Fire --- examples/kafka/kafka.py | 2 +- requirements.txt | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/examples/kafka/kafka.py b/examples/kafka/kafka.py index 6f52b682..3ec8ca27 100644 --- a/examples/kafka/kafka.py +++ b/examples/kafka/kafka.py @@ -22,4 +22,4 @@ def main(): if __name__ == '__main__': - main() + main() \ No newline at end of file diff --git a/requirements.txt b/requirements.txt index 9c558e35..1de34d82 100644 --- a/requirements.txt +++ b/requirements.txt @@ -1 +1,2 @@ . +kafka-python==1.4.4 \ No newline at end of file