Druid Can't get data after get some error message.

Hello. Can I ask some error msg?

I using kafka, tranquility, druid(imply1.1.0). And I can see data on druid side with GUI.

But after got error msg, I can’t get any data. Should I change some offset configuration?

Please see below msg,

filename: /usr/local/imply-1.1.0/var/sv/tranquility-kafka.log


06:36:09.672 [KafkaConsumer-0-SendThread(localhost:2181)] INFO  org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x154c293b6050002, negotiated timeout = 40000

06:36:09.876 [KafkaConsumer-0-EventThread] INFO  o.a.c.f.state.ConnectionStateManager - State change: CONNECTED

06:36:12.230 [KafkaConsumer-0] INFO  c.metamx.emitter.core.LoggingEmitter - Start: started [true]

06:36:13.508 [main-SendThread(localhost:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0x154c293b6050001 after 1ms

06:36:18.179 [KafkaConsumer-0] DEBUG c.m.t.tranquilizer.Tranquilizer - Swapping out buffer with 1 messages, 1 batches now pending.

06:33:12.839 [KafkaConsumer-1-SendThread(localhost:2181)] INFO  org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x154c28ba6340044, negotiated timeout = 40000

06:33:12.846 [KafkaConsumer-1-EventThread] INFO  o.a.c.f.state.ConnectionStateManager - State change: CONNECTED

06:33:13.164 [KafkaConsumer-1] INFO  c.metamx.emitter.core.LoggingEmitter - Start: started [true]

06:33:14.151 [KafkaConsumer-1] DEBUG c.m.t.tranquilizer.Tranquilizer - Swapping out buffer with 1 messages, 1 batches now pending.

06:33:14.152 [KafkaConsumer-1] DEBUG c.m.t.tranquilizer.Tranquilizer - Sending buffer with 1 messages.

06:33:14.267 [KafkaConsumer-1] DEBUG c.m.t.tranquilizer.Tranquilizer - Sent 0 out of 1 messages.

06:33:14.268 [KafkaConsumer-1] DEBUG c.m.t.tranquilizer.Tranquilizer - Sent buffer, 0 batches pending.

06:33:14.269 [KafkaConsumer-1] DEBUG kafka.consumer.PartitionTopicInfo - reset consume offset of twitter:0: fetched offset = 123398: consumed offset = 116214 to 116214

06:33:14.296 [KafkaConsumer-1] ERROR c.m.tranquility.kafka.KafkaConsumer - Exception:

com.metamx.tranquility.tranquilizer.MessageDroppedException: null

        at com.twitter.finagle.NoStacktrace(Unknown Source) ~[na:na]

06:33:14.297 [KafkaConsumer-1] INFO  c.m.tranquility.kafka.KafkaConsumer - Shutting down - attempting to flush buffers and commit final offsets

06:33:14.300 [Tranquilizer-BackgroundSend-[ClusteredBeam(druid:overlord/metrics-kafka)]] DEBUG c.m.t.tranquilizer.Tranquilizer - Interrupted, exiting thread.

May 18, 2016 6:33:14 AM com.twitter.finagle.Init$$anonfun$1 apply$mcV$sp

INFO: Finagle version 6.31.0 (rev=50d3bb0eea5ad3ed332111d707184c80fed6a506) built at 20151203-164135

.......

06:36:18.180 [KafkaConsumer-0] DEBUG c.m.t.tranquilizer.Tranquilizer - Sending buffer with 1 messages.

06:36:18.806 [KafkaConsumer-0] DEBUG c.m.t.tranquilizer.Tranquilizer - Sent 0 out of 1 messages.

06:36:18.808 [KafkaConsumer-0] DEBUG c.m.t.tranquilizer.Tranquilizer - Sent buffer, 0 batches pending.

06:36:18.813 [KafkaConsumer-CommitThread] ERROR c.m.tranquility.kafka.KafkaConsumer - Commit thread failed!

com.metamx.tranquility.tranquilizer.MessageDroppedException: null

        at com.twitter.finagle.NoStacktrace(Unknown Source) ~[na:na]

06:36:18.814 [KafkaConsumer-CommitThread] INFO  c.m.tranquility.kafka.KafkaConsumer - Shutting down - attempting to flush buffers and commit final offsets

06:36:18.816 [Tranquilizer-BackgroundSend-[ClusteredBeam(druid:overlord/metrics-kafka)]] DEBUG c.m.t.tranquilizer.Tranquilizer - Interrupted, exiting thread.

May 18, 2016 6:36:18 AM com.twitter.finagle.Init$$anonfun$1 apply$mcV$sp

INFO: Finagle version 6.31.0 (rev=50d3bb0eea5ad3ed332111d707184c80fed6a506) built at 20151203-164135

Duplicated by https://groups.google.com/forum/#!topic/druid-development/MxXHNFbU4qI