Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- demo-quartz_1 | web - 2018-05-15 11:42:21,635 [scheduler_Worker-1] INFO c.a.d.service.SampleJobService - created entity...
- demo-quartz_1 | web - 2018-05-15 11:42:21,635 [scheduler_Worker-1] INFO c.a.d.service.SampleJobService - BitcoinEuroEntity [idBCEntity=17, id=bitcoin, name=Bitcoin, symbol=BTC, rank=1, priceUsd=8792.3, priceBtc=1.0, _24hVolumeUsd=7220550000.0, marketCapUsd=149774518125, availableSupply=17034737.0, totalSupply=17034737.0, maxSupply=21000000.0, percentChange1h=0.22, percentChange24h=4.01, percentChange7d=-5.11, lastUpdated=1526384371, priceEur=7379.7202897, _24hVolumeEur=6060489216.45, marketCapEur=125711594269]
- demo-quartz_1 | web - 2018-05-15 11:42:21,636 [scheduler_Worker-1] INFO c.a.d.service.SampleJobService - entity sent to topic...
- demo-kafka-elastic_1 | web - 2018-05-15 11:42:21,640 [org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1] INFO c.a.demo.kafka.MessageListener - kafka message: BitcoinEuroKafkaEntity [id=17, name=Bitcoin, symbol=BTC, rank=1, priceUsd=8792.3, priceBtc=1.0, _24hVolumeUsd=7220550000.0, marketCapUsd=149774518125, availableSupply=17034737.0, totalSupply=17034737.0, maxSupply=21000000.0, percentChange1h=0.22, percentChange24h=4.01, percentChange7d=-5.11, lastUpdated=1526384371, priceEur=7379.7202897, _24hVolumeEur=6060489216.45, marketCapEur=125711594269]
- demo-kafka-elastic_1 | web - 2018-05-15 11:42:21,641 [org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1] ERROR o.s.k.listener.LoggingErrorHandler - Error while processing: ConsumerRecord(topic = aironman, partition = 0, offset = 102, CreateTime = 1526384541636, checksum = 1390061289, serialized key size = -1, serialized value size = 427, key = null, value = BitcoinEuroKafkaEntity [id=17, name=Bitcoin, symbol=BTC, rank=1, priceUsd=8792.3, priceBtc=1.0, _24hVolumeUsd=7220550000.0, marketCapUsd=149774518125, availableSupply=17034737.0, totalSupply=17034737.0, maxSupply=21000000.0, percentChange1h=0.22, percentChange24h=4.01, percentChange7d=-5.11, lastUpdated=1526384371, priceEur=7379.7202897, _24hVolumeEur=6060489216.45, marketCapEur=125711594269])
- demo-kafka-elastic_1 | org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.aironman.demo.kafka.MessageListener.bitCoinListener(com.aironman.demo.kafka.BitcoinEuroKafkaEntity)' threw exception; nested exception is NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{elastic}{172.21.0.6:9300}]]
- demo-kafka-elastic_1 | at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:188)
- demo-kafka-elastic_1 | at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:72)
- demo-kafka-elastic_1 | at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:47)
- demo-kafka-elastic_1 | at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:792)
- demo-kafka-elastic_1 | at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:736)
- demo-kafka-elastic_1 | at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:568)
- demo-kafka-elastic_1 | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
- demo-kafka-elastic_1 | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
- demo-kafka-elastic_1 | at java.lang.Thread.run(Thread.java:748)
- demo-kafka-elastic_1 | Caused by: org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: [{#transport#-1}{elastic}{172.21.0.6:9300}]
- demo-kafka-elastic_1 | at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:326)
- demo-kafka-elastic_1 | at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:223)
- demo-kafka-elastic_1 | at org.elasticsearch.client.transport.support.TransportProxyClient.execute(TransportProxyClient.java:55)
- demo-kafka-elastic_1 | at org.elasticsearch.client.transport.TransportClient.doExecute(TransportClient.java:295)
- demo-kafka-elastic_1 | at org.elasticsearch.client.support.AbstractClient.execute(AbstractClient.java:359)
- demo-kafka-elastic_1 | at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:86)
- demo-kafka-elastic_1 | at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:56)
- demo-kafka-elastic_1 | at org.springframework.data.elasticsearch.core.ElasticsearchTemplate.index(ElasticsearchTemplate.java:536)
- demo-kafka-elastic_1 | at org.springframework.data.elasticsearch.repository.support.AbstractElasticsearchRepository.save(AbstractElasticsearchRepository.java:147)
- demo-kafka-elastic_1 | at sun.reflect.GeneratedMethodAccessor66.invoke(Unknown Source)
- demo-kafka-elastic_1 | at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
- demo-kafka-elastic_1 | at java.lang.reflect.Method.invoke(Method.java:498)
- demo-kafka-elastic_1 | at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.executeMethodOn(RepositoryFactorySupport.java:515)
- demo-kafka-elastic_1 | at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.doInvoke(RepositoryFactorySupport.java:500)
- demo-kafka-elastic_1 | at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.invoke(RepositoryFactorySupport.java:477)
- demo-kafka-elastic_1 | at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
- demo-kafka-elastic_1 | at org.springframework.data.projection.DefaultMethodInvokingMethodInterceptor.invoke(DefaultMethodInvokingMethodInterceptor.java:56)
- demo-kafka-elastic_1 | at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
- demo-kafka-elastic_1 | at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
- demo-kafka-elastic_1 | at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
- demo-kafka-elastic_1 | at org.springframework.data.repository.core.support.SurroundingTransactionDetectorMethodInterceptor.invoke(SurroundingTransactionDetectorMethodInterceptor.java:57)
- demo-kafka-elastic_1 | at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
- demo-kafka-elastic_1 | at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:213)
- demo-kafka-elastic_1 | at com.sun.proxy.$Proxy62.save(Unknown Source)
- demo-kafka-elastic_1 | at com.aironman.demo.es.service.BitCoinESServiceImpl.save(BitCoinESServiceImpl.java:20)
- demo-kafka-elastic_1 | at com.aironman.demo.kafka.MessageListener.bitCoinListener(MessageListener.java:88)
- demo-kafka-elastic_1 | at sun.reflect.GeneratedMethodAccessor65.invoke(Unknown Source)
- demo-kafka-elastic_1 | at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
- demo-kafka-elastic_1 | at java.lang.reflect.Method.invoke(Method.java:498)
- demo-kafka-elastic_1 | at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:180)
- demo-kafka-elastic_1 | at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:112)
- demo-kafka-elastic_1 | at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48)
- demo-kafka-elastic_1 | at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:174)
- demo-kafka-elastic_1 | ... 8 common frames omitted
- demo-kafka-elastic_1 | web - 2018-05-15 11:42:22,379 [elasticsearch[Nanny][generic][T#1]] WARN org.elasticsearch.client.transport - [Nanny] node {#transport#-1}{elastic}{172.21.0.6:9300} not part of the cluster Cluster [elasticsearch_aironman], ignoring...
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement