intelmq.bots.collectors.kafka namespace

Submodules

intelmq.bots.collectors.kafka.collector module

Kafka Collector Bot

Collects information from the Apache Kafka distributed stream processing system.

param topic:

topic to collect information from

type topic:

str

param bootstrap_servers:

the ‘host[:port]’ string of the Apache Kafka system. Defaults to localhost:9092

type bootstrap_servers:

str

intelmq.bots.collectors.kafka.collector.BOT

alias of KafkaCollectorBot

class intelmq.bots.collectors.kafka.collector.KafkaCollectorBot(*args, **kwargs)

Bases: CollectorBot

Fetch data from the Apache Kafka distributed stream processing system

bootstrap_servers: str = 'localhost:9092'

init()

process()

Fetch messages from the Kafka server and pass them on one by one

ssl_cafile = None

ssl_certfile = None

ssl_check_hostname = None

topic = []