osint-python-test-bed-adapter 2.2.1

Python adapter for Kafka

naas-python-kafka

This is the kafka adapter for Python: it allows you to easily connect Python services to Apache Kafka via Python.

The implementation is a wrapper around Confluent-kafka-python

• AVRO schema's and messages: both key's and values should have a schema as explained here.
• Kafka consumer and producer for the test-bed topics.
• Management
  • Heartbeat (topic: system-heartbeat), so you know which clients are online. Each time the test-bed-adapter is executed, it starts a heartbeat process to notify the its activity to other clients.

Installation

You need to install Python 3+.

To run the examples you will need to install the dependencies specified on the file requirements.txt For that, run pip3 install -r requirements.txt from the project folder.

Examples and usage

• url_producer: creates a message with 4 URLs to RSS feeds on the topic ('system_rss_urls')
• rss_producer: listens to url messages ('system_rss_urls') and produces RSS messages ('system_rss_urls')
• rss_consumer: listens to RSS messages ('system_rss_urls') and prints them to console.