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
= []¶
-