Hi Marcus,

One thing that changed in 0.9.0.0 is that we now use `NetworkClient` for
inter-broker communication. `NetworkClient` is also used by the new Java
producer and consumer. Does the Java producer in 0.8.2 work fine for you?

Ismael

On Mon, Feb 22, 2016 at 3:06 PM, Marcus Gründler <marcus.gruend...@aixigo.de
> wrote:

> Hi All,
>
> the same happens for Kafka 0.9.0.1. The controller is unable to setup a
> connection on the local machine. I tried to set the following
> configurations in config/server.properties
>
> host.name=localhost
> advertised.host.name=localhost
> controller.socket.timeout.ms=245000
>
> without any luck. The SocketTimeoutExceptions can be observed every 30
> seconds in the controller.log. At every exception I can see another TCP
> TIME_WAIT entry in netstat | grep 9092.
>
> It seems that there ist some new behavior in the connection code between
> controller and broker that has changed since 0.8.2.
>
> Does anybody have an idea on how to fix it?
>
> Regards, Marcus
>
>
> > Am 19.02.2016 um 13:11 schrieb Lukas Banduch <lukas.band...@aixigo.de>:
> >
> > Hi,
> >
> > I'm desperately trying to run Kafka 0.9.0.0 on Solaris 5.10 (Kafka 0.8.2
> is working fine). I use 1 Broker with default configuration just as in the
> quickstart guide.
> > The Broker is not working and I see SocketTimeoutExceptions in the
> controller.log.
> >
> > Kafka is running on Java 1.8,B Filesystem is ufs
> >
> > Exception from controller.log:
> >
> > [2016-02-19 11:59:23,274] WARN [Controller-0-to-broker-0-send-thread],
> Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9093)
> was unsuccessful (kafka.controller.RequestSendThread)
> > java.net.SocketTimeoutException: Failed to connect within 30000 ms
> > B B B at
> kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:228)
> > B B B at
> kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172)
> > B B B at
> kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171)
> > B B B at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
> >
> > The entire logs are attatched.
> >
> > Thanks in advance
> >
> > --
> > aixigo AG - einfach. besser. beraten
> > Karl-Friedrich-StraC e 68, 52072 Aachen, Germany
> > fon: +49 (0)241 559709-364, fax: +49 (0)241 559709-99
> > eMail:
> > lukas.band...@aixigo.de, web: http://www.aixigo.de
> >
> >
> > Amtsgericht Aachen - HRB 8057
> > Vorstand: Erich Borsch, Christian Friedrich, Tobias Haustein
> > Vors. des Aufsichtsrates: Prof. Dr. RC
> >
> > <controller.log.2016-02-19-11><server.log.2016-02-19-11>
>
> --
>
> aixigo AG - einfach. besser. beraten
> Karl-Friedrich-Straße 68, 52072 Aachen, Germany
> fon: +49 (0)241 559709-43, fax: +49 (0)241 559709-99
> eMail: marcus.gruend...@aixigo.de, web: http://www.aixigo.de
>
> Amtsgericht Aachen - HRB 8057
> Vorstand: Erich Borsch, Christian Friedrich, Tobias Haustein
> Vors. des Aufsichtsrates: Prof. Dr. Rüdiger von Nitzsch
>
>

Reply via email to