Hi, Some strange is happening. We are still trying to run our application on multi node set up (same physical server).
While calling the method compute.broadcast getting an exception from kafka producer.send(), it is only happening while a multi node set up. if we are running the application on local it's working as expected. could you please let me know where is the issue ? it is on kafka side or ignite ? *sample code:* compute.broadcast(object1); ** object one has record,log and object of kafka producer ------- producer.send(new ProducerRecord<String, byte[]>(topicname,id, binarydata)); *Exception:* java.io.IOException: Bad file descriptor at sun.nio.ch.EPollArrayWrapper.interrupt(Native Method) at sun.nio.ch.EPollArrayWrapper.interrupt(EPollArrayWrapper.java:317) at sun.nio.ch.EPollSelectorImpl.wakeup(EPollSelectorImpl.java:207) at org.apache.kafka.common.network.Selector.wakeup(Selector.java:240) at org.apache.kafka.clients.NetworkClient.wakeup(NetworkClient.java:497) at org.apache.kafka.clients.producer.internals.Sender.wakeup(Sender.java:674) at org.apache.kafka.clients.producer.KafkaProducer.waitOnMetadata(KafkaProducer.java:823) at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:711) at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:701) at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:609) at sample.code.example.C_RTR_KafkaProducer2.send(C_RTR_KafkaProducer2.java:66) at sample.code.example.KafkaFileConsumerThread.sendToCOMMS(KafkaFileConsumerThread.java:320) at sample.code.example.KafkaFileConsumerThread.generateBinaryClearingMsg(KafkaFileConsumerThread.java:295) at sample.code.example.KafkaFileConsumerThread.populateClearingMsgObj(KafkaFileConsumerThread.java:207) at sample.code.example.KafkaFileConsumerThread.run(KafkaFileConsumerThread.java:154) at org.apache.ignite.internal.processors.closure.GridClosureProcessor$C4V2.execute(GridClosureProcessor.java:2215) at org.apache.ignite.internal.processors.job.GridJobWorker$2.call(GridJobWorker.java:556) at org.apache.ignite.internal.util.IgniteUtils.wrapThreadLoader(IgniteUtils.java:6564) at org.apache.ignite.internal.processors.job.GridJobWorker.execute0(GridJobWorker.java:550) at org.apache.ignite.internal.processors.job.GridJobWorker.body(GridJobWorker.java:479) at org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110) at org.apache.ignite.internal.processors.job.GridJobProcessor.processJobExecuteRequest(GridJobProcessor.java:1180) at org.apache.ignite.internal.processors.job.GridJobProcessor$JobExecutionListener.onMessage(GridJobProcessor.java:1894) at org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1082) at org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:710) at org.apache.ignite.internal.managers.communication.GridIoManager.access$1700(GridIoManager.java:102) at org.apache.ignite.internal.managers.communication.GridIoManager$5.run(GridIoManager.java:673) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) -- Regards, Rajarshi Pain
