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 intelmq.bots.collectors.kafka.collector.KafkaCollectorBot

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

Bases: intelmq.lib.bot.CollectorBot

Fetch data from the Apache Kafka distributed stream processing system

bootstrap_servers = '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 = []