Hi,
we are getting NoClassDefFoundError at our producer end. We are using only
syn producer. we have 3 data producer systems whose using same
kafka.javaapi.producer.Producer instance.Bellow is the maven dependency
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.10</artifactId>
<version>0.8.2.1</version>
</dependency>
Bellow is the stack trace of exception.
Exception in thread "ActiveMQ Session Task-1749"
java.lang.NoClassDefFoundError:
kafka/producer/async/DefaultEventHandler$$anonfun$dispatchSerializedData$3
at
kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:99)
at
kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72)
at kafka.producer.Producer.send(Producer.scala:77)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at
com.snapdeal.services.requeue.impl.RequeueServiceImpl.producerSend(RequeueServiceImpl.java:107)
at
com.snapdeal.services.requeue.impl.RequeueServiceImpl.requeueToKafka(RequeueServiceImpl.java:86)
at
com.snapdeal.services.requeue.impl.RequeueServiceImpl.requeue(RequeueServiceImpl.java:71)
at
com.snapdeal.services.indexer.impl.IndexerCatalogServiceImpl.indexCatalogInfo(IndexerCatalogServiceImpl.java:344)
at
com.snapdeal.services.indexer.impl.SupcIndexerServiceImpl.index(SupcIndexerServiceImpl.java:63)
at
com.snapdeal.indexer.listener.impl.InventoryUpdateQueueListener.index(InventoryUpdateQueueListener.java:73)
at
com.snapdeal.indexer.listener.AbstractQueueListenerService.callIndex(AbstractQueueListenerService.java:82)
at
com.snapdeal.indexer.listener.impl.InventoryUpdateQueueListener.onMessage(InventoryUpdateQueueListener.java:92)
at
org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1298)
at
org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:131)
at
org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:202)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
00:00:15,525#
[requestId=142967906333580768|appIdent=SearchAdmin|appIP=30.0.0.165|apiVariantId=null]
ERROR [HttpSender] - Error http to : http:
//
internal-catalog-lb-mw-2086838461.ap-southeast-1.elb.amazonaws.com:8080/service/product/getPOGDetailListByIdList
java.net.SocketException: Too many open files
at java.net.Socket.createImpl(Socket.java:447)
at java.net.Socket.getImpl(Socket.java:510)
at java.net.Socket.setSoTimeout(Socket.java:1105)
at
org.apache.http.conn.scheme.PlainSocketFactory.connectSocket(PlainSocketFactory.java:116)
at
org.apache.http.impl.conn.DefaultClientConnectionOperator.openConnection(DefaultClientConnectionOperator.java:177)
at
org.apache.http.impl.conn.AbstractPoolEntry.open(AbstractPoolEntry.java:144)
at
org.apache.http.impl.conn.AbstractPooledConnAdapter.open(AbstractPooledConnAdapter.java:131)
at
org.apache.http.impl.client.DefaultRequestDirector.tryConnect(DefaultRequestDirector.java:610)
at
org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:445)
at
org.apache.http.impl.client.AbstractHttpClient.doExecute(AbstractHttpClient.java:863)
at
org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:82)
at
org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:106)
at
org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:57)
Could you please help us to resolve these two issue?
Regards,
Abdul Hameed
+919599216373
