org.springframework.data.cassandra.CassandraInternalException: Query; CQL [INSERT INTO handled_tx (tx_id,currency_code,direction,handled_tx_type,offset) VALUES ('d:43e6285b99e5dd0a747962f31d006df36e39cd1abca6777da098b7c455c01b98:0','BCH','DEPOSIT','USER_TX',925);]; An unexpected error happened while sending requests; nested exception is com.datastax.driver.core.exceptions.DriverInternalError: An unexpected error happened while sending requestsat org.springframework.data.cassandra.core.cql.CassandraExceptionTranslator.translate(CassandraExceptionTranslator.java:93) ~[spring-data-cassandra-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.data.cassandra.core.cql.CassandraAccessor.translate(CassandraAccessor.java:334) ~[spring-data-cassandra-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.data.cassandra.core.cql.CqlTemplate.translateException(CqlTemplate.java:725) ~[spring-data-cassandra-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.data.cassandra.core.cql.CqlTemplate.query(CqlTemplate.java:297) ~[spring-data-cassandra-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.data.cassandra.core.cql.CqlTemplate.queryForResultSet(CqlTemplate.java:375) ~[spring-data-cassandra-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.data.cassandra.core.cql.CqlTemplate.execute(CqlTemplate.java:277) ~[spring-data-cassandra-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.data.cassandra.repository.support.SimpleCassandraRepository.save(SimpleCassandraRepository.java:79) ~[spring-data-cassandra-2.0.5.RELEASE.jar:2.0.5.RELEASE]at sun.reflect.GeneratedMethodAccessor22.invoke(Unknown Source) ~[na:na]at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_201]at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_201]at org.springframework.data.repository.core.support.RepositoryComposition$RepositoryFragments.invoke(RepositoryComposition.java:377) ~[spring-data-commons-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.data.repository.core.support.RepositoryComposition.invoke(RepositoryComposition.java:200) ~[spring-data-commons-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.data.repository.core.support.RepositoryFactorySupport$ImplementationMethodExecutionInterceptor.invoke(RepositoryFactorySupport.java:629) ~[spring-data-commons-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.4.RELEASE.jar:5.0.4.RELEASE]at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.doInvoke(RepositoryFactorySupport.java:593) ~[spring-data-commons-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.invoke(RepositoryFactorySupport.java:578) ~[spring-data-commons-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.4.RELEASE.jar:5.0.4.RELEASE]at org.springframework.data.projection.DefaultMethodInvokingMethodInterceptor.invoke(DefaultMethodInvokingMethodInterceptor.java:59) ~[spring-data-commons-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.4.RELEASE.jar:5.0.4.RELEASE]at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92) ~[spring-aop-5.0.4.RELEASE.jar:5.0.4.RELEASE]at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.4.RELEASE.jar:5.0.4.RELEASE]at org.springframework.data.repository.core.support.SurroundingTransactionDetectorMethodInterceptor.invoke(SurroundingTransactionDetectorMethodInterceptor.java:61) ~[spring-data-commons-2.0.5.RELEASE.jar:2.0.5.RELEASE]at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.4.RELEASE.jar:5.0.4.RELEASE]at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:212) ~[spring-aop-5.0.4.RELEASE.jar:5.0.4.RELEASE]at com.sun.proxy.$Proxy122.save(Unknown Source) ~[na:na]at io.nominex.coin.worker.pending.HandledTxManager.saveTxHandled(HandledTxManager.java:53) ~[classes/:na]at io.nominex.coin.worker.pending.UserTxHandler.processUnhandledTransaction(UserTxHandler.java:126) ~[classes/:na]at io.nominex.coin.worker.pending.UserTxHandler.handle(UserTxHandler.java:102) ~[classes/:na]at io.nominex.coin.worker.pending.UserTxConsumer.lambda$null$0(UserTxConsumer.java:69) ~[classes/:na]at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) ~[na:1.8.0_201]at java.util.Iterator.forEachRemaining(Iterator.java:116) ~[na:1.8.0_201]at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801) ~[na:1.8.0_201]at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481) ~[na:1.8.0_201]at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471) ~[na:1.8.0_201]at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:545) ~[na:1.8.0_201]at java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) ~[na:1.8.0_201]at java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:438) ~[na:1.8.0_201]at io.nominex.coin.worker.pending.UserTxConsumer.lambda$consume$2(UserTxConsumer.java:72) ~[classes/:na]at io.nominex.kafka.common.TxKafkaPublisher.executeTx(TxKafkaPublisher.java:39) ~[kafka-common-0.0.1-SNAPSHOT.jar:0.0.1-SNAPSHOT]at io.nominex.coin.worker.pending.UserTxConsumer.consume(UserTxConsumer.java:61) ~[classes/:na]at io.nominex.kafka.common.DelegatingKafkaConsumer.consume(DelegatingKafkaConsumer.java:67) ~[kafka-common-0.0.1-SNAPSHOT.jar:0.0.1-SNAPSHOT]at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_201]Caused by: com.datastax.driver.core.exceptions.DriverInternalError: An unexpected error happened while sending requestsat com.datastax.driver.core.exceptions.DriverInternalError.copy(DriverInternalError.java:42) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.exceptions.DriverInternalError.copy(DriverInternalError.java:24) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:68) ~[cassandra-driver-core-3.4.0.jar:na]at org.springframework.data.cassandra.core.cql.CqlTemplate.query(CqlTemplate.java:295) ~[spring-data-cassandra-2.0.5.RELEASE.jar:2.0.5.RELEASE]... 38 common frames omittedCaused by: com.datastax.driver.core.exceptions.DriverInternalError: An unexpected error happened while sending requestsat com.datastax.driver.core.RequestHandler$SpeculativeExecution.findNextHostAndQuery(RequestHandler.java:321) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.RequestHandler.startNewExecution(RequestHandler.java:120) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.RequestHandler.sendRequest(RequestHandler.java:100) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.SessionManager.executeAsync(SessionManager.java:132) ~[cassandra-driver-core-3.4.0.jar:na]... 40 common frames omittedCaused by: com.datastax.driver.core.exceptions.ConnectionException: [cassandra/10.4.7.98:9042] Write attempt on defunct connectionat com.datastax.driver.core.Connection.write(Connection.java:593) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.Connection.write(Connection.java:575) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.Connection.write(Connection.java:570) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.Connection.setKeyspaceAsync(Connection.java:528) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.HostConnectionPool.borrowConnection(HostConnectionPool.java:272) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.RequestHandler$SpeculativeExecution.query(RequestHandler.java:337) ~[cassandra-driver-core-3.4.0.jar:na]at com.datastax.driver.core.RequestHandler$SpeculativeExecution.findNextHostAndQuery(RequestHandler.java:300) ~[cassandra-driver-core-3.4.0.jar:na]... 43 common frames omitted

2019-04-24 10:10:25.608 INFO 1 --- [ Thread-4] s.c.a.AnnotationConfigApplicationContext : Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@14a2f921: startup date [Thu Apr 18 04:37:55 GMT 2019]; root of context hierarchy2019-04-24 10:10:25.612 INFO 1 --- [ Thread-4] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService2019-04-24 10:10:25.623 INFO 1 --- [ Thread-4] o.s.c.support.DefaultLifecycleProcessor : Stopping beans in phase 21474835472019-04-24 10:10:25.631 INFO 1 --- [tListener-0-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService2019-04-24 10:10:25.637 INFO 1 --- [tListener-0-C-1] essageListenerContainer$ListenerConsumer : Consumer stopped2019-04-24 10:10:25.640 INFO 1 --- [ Thread-4] o.s.j.e.a.AnnotationMBeanExporter : Unregistering JMX-exposed beans on shutdown2019-04-24 10:10:25.641 INFO 1 --- [ Thread-4] o.s.j.e.a.AnnotationMBeanExporter : Unregistering JMX-exposed beans2019-04-24 10:10:25.644 WARN 1 --- [ Thread-4] o.s.b.f.support.DisposableBeanAdapter : Invocation of destroy method 'close' failed on bean with name 'kafkaTxPublisherConsumer': java.util.ConcurrentModifi