91af4ae6f0
reads PCAP input from file system, stdin, or by listening on a network interface. Furthermore, the parser is able to use several output filters and pipes to tailor the output for your individual needs. OK sthen@
42 lines
2.0 KiB
Plaintext
42 lines
2.0 KiB
Plaintext
$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.")
|
|
|