私はDruidを初めて使用しています。私はImply IAP packageを使ってクラスタを設定しました。 イベントは、Tranquilityを使用してカフカのドルイドに摂取されています。私はイベントが静寂で受け入れられていることがわかります - 次のログ・ステートメントは、私はそれを検証するために使用されるものです:ドルイドブローカーによってUnresolvedAddressExceptionが発生しました
2016-10-03 19:19:22,715 [KafkaConsumer-CommitThread] INFO c.m.tranquility.kafka.KafkaConsumer - Flushed {conn_recs={receivedCount=1, sentCount=1, droppedCount=0, unparseableCount=0}} pending messages in 32056ms and committed offsets in 15ms.
しかし、ブローカーは、私が上timeBoundaryクエリを実行しようとすると例外を打つているように見えます情報元。続き
は(ブローカーのログからコピーされた)例外スタックトレースです:
java.nio.channels.UnresolvedAddressException
at sun.nio.ch.Net.checkAddress(Net.java:101) ~[?:1.8.0_66]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:622) ~[?:1.8.0_66]
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:108) [netty-3.10.4.Final.jar:?]
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:70) [netty-3.10.4.Final.jar:?]
at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendDownstream(DefaultChannelPipeline.java:779) [netty-3.10.4.Final.jar:?]
at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54) [netty-3.10.4.Final.jar:?]
私は私がに見て必要/プロセスをログに記録しているかわからないので、私はしばらくの間、この時点で立ち往生してきましたこれをさらにデバッグします。
質問:誰かが、このような問題をデバッグする方法を説明することができますか?たとえば、私が見なければならない特定のログなどですか?
Btw、私は別の3ノードのzookeeperクラスタと単一ノードのmysqlインスタンスをドルイドクラスターの外部依存関係として使用しています。
詳細をお知らせください。
おかげで、 Jithin