Found following error in server.log file under log folder.
ERROR Closing socket for /x.x.x.x because of error (kafka.network.Processor)
java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
at sun.nio.ch.IOUtil.read(IOUtil.java:197)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379)
at kafka.utils.Utils$.read(Utils.scala:380)
at
kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
at kafka.network.Processor.read(SocketServer.scala:444)
at kafka.network.Processor.run(SocketServer.scala:340)
at java.lang.Thread.run(Thread.java:745)
On Fri, Oct 16, 2015 at 11:35 AM, Kiran Singh <kim.sing...@gmail.com> wrote:
> Hi Mayuresh
>
> Can you please share how and from where i can collect logs.
>
> On Fri, Oct 16, 2015 at 9:53 AM, Kiran Singh <kim.sing...@gmail.com>
> wrote:
>
>> Hi Mayuresh
>>
>> I am following link
>>
>> https://cwiki.apache.org/confluence/display/KAFKA/Committing+and+fetching+consumer+offsets+in+Kafka
>>
>> for implementing commit and fech offset API and i am using
>> kafka_2.10-0.8.2.2 jar file.
>>
>> On Thu, Oct 15, 2015 at 9:40 PM, Mayuresh Gharat <
>> gharatmayures...@gmail.com> wrote:
>>
>>> This means that there is no coordinator available for the consumer group.
>>> Can you send the log. Also which consumer are you using. Is there a wiki
>>> you are referring to, to implement the commit and fetch offset API?
>>>
>>> Thanks,
>>>
>>> Mayuresh
>>>
>>> On Thu, Oct 15, 2015 at 7:17 AM, Kiran Singh <kim.sing...@gmail.com>
>>> wrote:
>>>
>>> > Hi
>>> >
>>> > I am trying to implement fetch and commit offset API. But i am getting
>>> > error code 15 "ConsumerCoordinatorNotAvailableCode" while connecting to
>>> > kafka.
>>> >
>>> > Can any one explain this error?
>>> >
>>> > Thanks and Regards
>>> > Kiran Singh
>>> >
>>>
>>>
>>>
>>> --
>>> -Regards,
>>> Mayuresh R. Gharat
>>> (862) 250-7125
>>>
>>
>>
>
