Hi all,
Wondering if anyone has a simillar problem with kafka plugin. nfacctd
dosn't send to kafka , using :
conf
---
kafka_topic: pmacct1
kafka_topic[test]: pmacct1
kafka_refresh_time[test]: 300
kafka_history[test]: 5m
kafka_history_roundoff[test]: m
---
logs:
Jul 27 23:55:01 DEBUG ( test/kafka ): {"peer_as_src": 0, "bytes": 2584,
"tag": 0, "tos": 192, "as_dst": 0, "comms": "", "net_dst": "0.0.0.0",
"as_src": 0, "stamp_updated": "2016-07-27 23:55:01", "net_src": "0.0.0.0",
"as_path": "", "mask_src": 0, "ip_proto": "ospf", "mask_dst": 0,
"local_pref": 0, "peer_ip_dst": "", "stamp_inserted": "2016-07-27
23:50:00", "med": 0, "peer_as_dst": 0, "peer_ip_src": "10.255.255.1",
"src_as_path":Jul 27 23:55:01 DEBUG ( ukb/kafka ): Kafka message delivery
successful (446 bytes): {"peer_as_src": 0, "bytes": 2584, "tag": 0, "tos":
192, "as_dst": 0, "comms": "", "net_dst": "0.0.0.0", "as_src": 0,
"stamp_updated": "2016-07-27 23:55:01", "net_src": "0.0.0.0", "as_path":
"", "mask_src": 0, "ip_proto": "ospf", "mask_dst": 0, "local_pref": 0,
"peer_ip_dst": "", "stamp_inserted": "2016-07-27 23:50:00", "med": 0,
"peer_as_dst": 0Jul 27 23:55:02 INFO ( test/kafka ): *** Purging cache -
END (PID: 7008, QN: 1/1, ET: 1) ***
--- consumer
./kafka-console-consumer.sh --topic pmacct1 --zookeeper localhost
--from-beginning
^CConsumed 0 messages
using librdkafka_0.8
Any pointers are much appreciated .
Regards,
Catalin
_______________________________________________
pmacct-discussion mailing list
http://www.pmacct.net/#mailinglists
