UNSUBSCRIBE PLEASE

[wi...@gmail.com]

-----Original Message-----
From: Kuldeep Kamboj [mailto:kuldeep.kamboj@osscube.com] 
Sent: Monday, May 2, 2016 11:29 PM
To: users@kafka.apache.org
Subject: Getting Timed out reading socket error for kafka cluster setup

Hi,

I want to setup a kafka cluster type setup for three similar application having same queues like AppA -> {TopicX, TopicY, TopicZ},  AppB -> {TopicX, TopicZ}, AppC -> {TopicX, TopicY}. Producer and Consumer will be App specific.
I setup kafka cluster with three brokers having partition 1,2,3 in three different config files with different ports. Then start kafka server ( cluster )

I am using kafka php wrapper by http://github.com/nmred/kafka-php

So I used Producer code for App A like

           $producer->setRequireAck(-1);
           $producer->setMessages("TopicX", 0, array(json_encode($this->data)));
           $producer->send();

AND used Producer code for App B like

           $producer->setRequireAck(-1);
           $producer->setMessages("TopicX", 1, array(json_encode($this->data)));
           $producer->send();

And So On.

Then I made my Consumer scripts for three apps like

            $queues = array("TopicX", "TopicY", "TopicZ");
            while(true) {
                foreach($queues as $queue) {
                    $consumer =
\Kafka\Consumer::getInstance('localhost:2181');
                    $consumer->setGroup('testgroup');
                    $consumer->setPartition($queue, 0);
                    $result = $consumer->fetch();
               }
            }

But when I try to execute consumer script for any App I get error like

**"Timed out reading socket while reading 750437 bytes with 750323 bytes to
go"**

I just don't know How I can fix this issue I tried to modify some kafka config parameters like

     zookeeper.connection.timeout.ms=24000         # Initially 6000
     replica.socket.timeout.ms=15000                      # Not exists in
default file

but that not worked.


--
Kuldeep Kamboj