#
# Destination definition for kafka-c . I had to install syslog-ng
# from git and then modify the config example in github. 
#
# A small % of the messages were creating errors, further 
# debugging required. 
#

destination d_kafka {
    channel {
        destination {
            kafka-c(
                bootstrap-servers("kafka1.host:9092,kafka2.host:9092")
                topic("bro-events")
                message("$(format-json --scope selected_macros --scope nv_pairs --exclude DATE --key ISODATE)\n")
            );
        };
    };
};