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
(bot_id: str, start: bool = False, sighup_event=None, disable_multithreading: bool = None)¶ Bases:
intelmq.lib.bot.CollectorBot
-
init
()¶
-
process
()¶ Fetch messages from the Kafka server and pass them on one by one
-