at2.sources =st2

at2.channels = ct2

at2.sinks = kt2

# For each one of the sources, the type is defined

at2.sources.st2.type = org.apache.flume.source.kafka.KafkaSource

at2.sources.st2.kafka.bootstrap.servers = node0.***:9200,node1.***:9200,node2.***:9200

at2.sources.st2.kafka.topics = flume-test

at2.sources.st2.kafka.consumer.group.id = flume-to-file-test-group-id

# The channel can be defined as follows.

at2.sources.st2.channels = ct2

at2.sources.st2.kafka.batchSize = 100

# Each sink's type must be defined

at2.sinks.kt2.type = file_roll

at2.sinks.kt2.sink.directory = /mnt/home/admin/install/flume/examples/file-dir

at2.sinks.kt2.batchSize = 100

at2.sinks.kt2.sink.rollInterval = 300

#Specify the channel the sink should use

at2.sinks.kt2.channel = ct2

# Each channel's type is defined.

at2.channels.ct2.type = memory

at2.channels.ct2.capacity = 1000

at2.channels.ct2.transactionCapacity = 1000

# Other config values specific to each type of channel(sink or source)

at2.sources.st2.channels = ct2

at2.sinks.kt2.channel = ct2