-
Notifications
You must be signed in to change notification settings - Fork 0
/
FlumeConfig.conf
24 lines (18 loc) · 972 Bytes
/
FlumeConfig.conf
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
TwitterAgent.sources = Twitter
TwitterAgent.channels = channel1
TwitterAgent.sinks = sink1
TwitterAgent.sources.Twitter.type = com.cloudera.flume.source.TwitterSource
TwitterAgent.sources.Twitter.consumerKey = ###########
TwitterAgent.sources.Twitter.consumerSecret = ##############
TwitterAgent.sources.Twitter.accessToken = ############################
TwitterAgent.sources.Twitter.accessTokenSecret = #################
TwitterAgent.sources.Twitter.channels = channel1
TwitterAgent.sources.Twitter.keywords = twitter
TwitterAgent.channels.channel1.type = memory
TwitterAgent.channels.channel1.capacity = 10000
TwitterAgent.channels.channel1.transactionCapacity = 100
TwitterAgent.sinks.sink1.channel = channel1
TwitterAgent.sinks.sink1.type = org.apache.flume.sink.kafka.KafkaSink
TwitterAgent.sinks.sink1.kafka.topic = topic_random
TwitterAgent.sinks.sink1.kafka.bootstrap.servers = localhost:9092,localhost:9092
TwitterAgent.sinks.sink1.kafka.batchsize = 10