| 123456789101112131415161718192021222324252627282930313233343536373839404142 |
- $OpenBSD: patch-pbgpp_Application_Handler_py,v 1.1.1.1 2017/01/13 14:15:41 phessler Exp $
- Avoid using Kafka
- --- pbgpp/Application/Handler.py.orig Fri Nov 25 10:19:53 2016
- +++ pbgpp/Application/Handler.py Fri Jan 13 12:18:39 2017
- @@ -46,7 +46,7 @@ from pbgpp.Output.Formatters.JSON import JSONFormatter
- from pbgpp.Output.Formatters.LineBased import LineBasedFormatter
- from pbgpp.Output.Handler import OutputHandler
- from pbgpp.Output.Pipes.FilePipe import FilePipe
- -from pbgpp.Output.Pipes.KafkaPipe import KafkaPipe
- +#from pbgpp.Output.Pipes.KafkaPipe import KafkaPipe
- from pbgpp.Output.Pipes.StdOutPipe import StdOutPipe
- from pbgpp.PCAP.Ethernet import PCAPEthernet
- from pbgpp.PCAP.IP import PCAPIP
- @@ -65,8 +65,8 @@ class PBGPPHandler:
- self.fields = None
- self.progress = False
-
- - self.kafka_server = None
- - self.kafka_topic = None
- +# self.kafka_server = None
- +# self.kafka_topic = None
-
- self.formatter = None
- self.pipe = None
- @@ -241,10 +241,10 @@ class PBGPPHandler:
- self.pipe = FilePipe(self.args.output_target)
- elif self.args.pipe == "STDOUT":
- self.pipe = StdOutPipe()
- - elif self.args.pipe == "KAFKA":
- - if self.args.kafka_server is None or self.args.kafka_topic is None:
- - self.__parser.error("You need to specify Kafka server (--kafka-server) and topic (--kafka-topic) when using KAFKA as output pipe.")
- - self.pipe = KafkaPipe(server=self.args.kafka_server, topic=self.args.kafka_topic)
- +# elif self.args.pipe == "KAFKA":
- +# if self.args.kafka_server is None or self.args.kafka_topic is None:
- +# self.__parser.error("You need to specify Kafka server (--kafka-server) and topic (--kafka-topic) when using KAFKA as output pipe.")
- +# self.pipe = KafkaPipe(server=self.args.kafka_server, topic=self.args.kafka_topic)
- else:
- self.__parser.error("Can't recognize the output pipe.")
-
|
