Я новичок в Druid. Я создал кластер, используя Imply IAP package. События попадают в Друид из Кафки, используя Tranquility. Я могу видеть, что события принимаются на 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:?]
Я застрял в этой точке времени, так как я не уверен, какие журналы/процессы, которые я должен смотреть в для дальнейшего отладки этого.
Вопрос: Может кто-нибудь объяснить, как мне нужно отлаживать такую проблему - то есть любые конкретные журналы, которые мне нужно посмотреть, и т. Д.?
Кстати, я использую отдельный кластер кластера с 3 узлами и экземпляр mysql одного узла как внешние зависимости для кластера друидов.
Пожалуйста, дайте мне знать, если мне нужно предоставить дополнительную информацию.
Спасибо, Jithin