# Flume agent config
     
    #### Global ####
    demo.sources = Netcat
    demo.channels = memory_channel
    demo.sinks = sink
     
    #### Sources ####
    demo.sources.Netcat.type = netcat 
    demo.sources.Netcat.bind = localhost
    demo.sources.Netcat.port = 56566
    demo.sources.Netcat.channels=memory_channel
     
    #### Sinks ####
    demo.sinks.sink.type = org.apache.flume.sink.kafka.KafkaSink
    demo.sinks.sink.channel = memory_channel
    demo.sinks.sink.topic = flume_topic
    demo.sinks.sink.brokerList = sandbox.hortonworks.com:6668,sandbox.hortonworks.com:6668
    demo.sinks.sink.bootstrap.servers = sandbox.hortonworks.com:6668,sandbox.hortonworks.com:6668
    demo.sinks.sink.security.protocol = SASL_SSL
    demo.sinks.sink.sasl.mechanism=GSSAPI
    demo.sinks.sink.sasl.kerberos.service.name = kafka
    demo.sinks.sink.ssl.truststore.location = /etc/security/certificate/server.truststore.jks
    demo.sinks.sink.ssl.truststore.password = sasl_ssl
    demo.sinks.sink.ssl.truststore.type=JKS
    demo.sinks.sink.generateKeytabFor=flume/sandbox.hortonworks.com@HADOOP.COM


    #### Channels ####
    demo.channels.memory_channel.type = memory
    demo.channels.memory_channel.capacity = 1000