Hi,
I am reading streams from Kafka topic (using ConsumerConnector with a thread
count 4). I observed that stream processing is very slow and sometimes I am
getting following exception. Could you please let me know what could be the
reason of this slow processing.
I am trying to read a log file with a record count of 200K.
SEVERE: Failed to request nodes addresses.
java.net.SocketException: bad argument for IP_MULTICAST_IF: address not bound
to any interface
at
java.net.TwoStacksPlainDatagramSocketImpl.socketSetOption(Native Method)
at
java.net.AbstractPlainDatagramSocketImpl.setOption(AbstractPlainDatagramSocketImpl.java:309)
at
java.net.MulticastSocket.setInterface(MulticastSocket.java:467)
at
org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder.requestAddresses(TcpDiscoveryMulticastIpFinder.java:544)
at
org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder.access$700(TcpDiscoveryMulticastIpFinder.java:80)
at
org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder$AddressReceiver.body(TcpDiscoveryMulticastIpFinder.java:755)
at
org.apache.ignite.spi.IgniteSpiThread.run(IgniteSpiThread.java:62)
Thanks
