but I after I change the kafka producer generator to meet the realtime.
It has something else.
2016-08-13 11:54:14,815 [KafkaConsumer-CommitThread] INFO c.m.tranquility.kafka.KafkaConsumer - Flushed 0 pending messages in 0ms and committed offsets in 0ms.
2016-08-13 11:54:20,218 [finagle/netty3-17] WARN c.m.tranquility.beam.ClusteredBeam - Emitting alert: [anomaly] Failed to propagate events: druid:overlord/pageviews-kafka
{
"eventCount" : 1,
"timestamp" : "2016-08-13T11:00:00.000Z",
"beams" : "MergingPartitioningBeam(DruidBeam(interval = 2016-08-13T11:00:00.000Z/2016-08-13T12:00:00.000Z, partition = 0, tasks = [index_realtime_pageviews-kafka_2016-08-13T11:00:00.000Z_0_0/pageviews-kafka-011-0000-0000]))"
}
com.twitter.finagle.ChannelWriteException: java.net.ConnectException: Connection refused: master3/10.197.0.5:8102 from service: druidTask!druid:overlord!index_realtime_pageviews-kafka_2016-08-13T11:00:00.000Z_0_0 at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.8.0_91]
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[na:1.8.0_91]
at org.jboss.netty.channel.socket.nio.NioClientBoss.connect(NioClientBoss.java:152) [io.netty.netty-3.10.5.Final.jar:na]
at org.jboss.netty.channel.socket.nio.NioClientBoss.processSelectedKeys(NioClientBoss.java:105) [io.netty.netty-3.10.5.Final.jar:na]
at org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:79) [io.netty.netty-3.10.5.Final.jar:na]
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337) [io.netty.netty-3.10.5.Final.jar:na]
at org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42) [io.netty.netty-3.10.5.Final.jar:na]
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) [io.netty.netty-3.10.5.Final.jar:na]
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) [io.netty.netty-3.10.5.Final.jar:na]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: java.net.ConnectException: Connection refused: master3/10.197.0.5:8102 ... 12 common frames omitted
2016-08-13 11:54:20,224 [finagle/netty3-17] INFO c.metamx.emitter.core.LoggingEmitter - Event [{"feed":"alerts","timestamp":"2016-08-13T11:54:20.223Z","service":"tranquility","host":"localhost","severity":"anomaly","description":"Failed to propagate events: druid:overlord/pageviews-kafka","data":{"exceptionType":"com.twitter.finagle.ChannelWriteException","exceptionStackTrace":"com.twitter.finagle.ChannelWriteException: java.net.ConnectException: Connection refused: master3/10.197.0.5:8102 from service: druidTask!druid:overlord!index_realtime_pageviews-kafka_2016-08-13T11:00:00.000Z_0_0\n\tat com.twitter.finagle.NoStacktrace(Unknown Source)\nCaused by: java.net.ConnectException: Connection refused: master3/10.197.0.5:8102\n\tat sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\n\tat sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)\n\tat org.jboss.netty.channel.socket.nio.NioClientBoss.connect(NioClientBoss.java:152)\n\tat org.jboss.netty.channel.socket.nio.NioClientBoss.processSelectedKeys(NioClientBoss.java:105)\n\tat org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:79)\n\tat org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)\n\tat org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42)\n\tat org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)\n\tat org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\n\tat java.lang.Thread.run(Thread.java:745)\n","timestamp":"2016-08-13T11:00:00.000Z","beams":"MergingPartitioningBeam(DruidBeam(interval = 2016-08-13T11:00:00.000Z/2016-08-13T12:00:00.000Z, partition = 0, tasks = [index_realtime_pageviews-kafka_2016-08-13T11:00:00.000Z_0_0/pageviews-kafka-011-0000-0000]))","eventCount":1,"exceptionMessage":"java.net.ConnectException: Connection refused: master3/10.197.0.5:8102 from service: druidTask!druid:overlord!index_realtime_pageviews-kafka_2016-08-13T11:00:00.000Z_0_0"}}] 2016-08-13 11:54:27,852 [finagle/netty3-17] WARN c.m.tranquility.beam.ClusteredBeam - Emitting alert: [anomaly] Failed to propagate events: druid:overlord/pageviews-kafka
{
"eventCount" : 1,
"timestamp" : "2016-08-13T11:00:00.000Z",
"beams" : "MergingPartitioningBeam(DruidBeam(interval = 2016-08-13T11:00:00.000Z/2016-08-13T12:00:00.000Z, partition = 0, tasks = [index_realtime_pageviews-kafka_2016-08-13T11:00:00.000Z_0_0/pageviews-kafka-011-0000-0000]))"
}
com.twitter.finagle.ChannelWriteException: java.net.ConnectException: Connection refused: master3/10.197.0.5:8102 from service: druidTask!druid:overlord!index_realtime_pageviews-kafka_2016-08-13T11:00:00.000Z_0_0 at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.8.0_91]
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[na:1.8.0_91]
at org.jboss.netty.channel.socket.nio.NioClientBoss.connect(NioClientBoss.java:152) [io.netty.netty-3.10.5.Final.jar:na]
at org.jboss.netty.channel.socket.nio.NioClientBoss.processSelectedKeys(NioClientBoss.java:105) [io.netty.netty-3.10.5.Final.jar:na]
at org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:79) [io.netty.netty-3.10.5.Final.jar:na]
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337) [io.netty.netty-3.10.5.Final.jar:na]
at org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42) [io.netty.netty-3.10.5.Final.jar:na]
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) [io.netty.netty-3.10.5.Final.jar:na]
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) [io.netty.netty-3.10.5.Final.jar:na]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: java.net.ConnectException: Connection refused: master3/10.197.0.5:8102 ... 12 common frames omitted