Re: Embedding zookeeper and kafka in java process.

okeeper-server-start.bat and started kafka > via > > > my java process and I saw same error. > > > But if I start zookeeper via java process and start kafka via > > > kafka-server-start.bat, t works fine. > > > It means it is not caused due to both getting started in sa

Re: Embedding zookeeper and kafka in java process.

parameters? It used to work with kafka 0.7.1. > > Thanks > Subhash Agrawal > > > -Original Message- > From: isma...@gmail.com [mailto:isma...@gmail.com] On Behalf Of Ismael > Juma > Sent: Thursday, June 16, 2016 1:38 AM > To: dev@kafka.apache.org > Subject: Re: Embedd

RE: Embedding zookeeper and kafka in java process.

: Re: Embedding zookeeper and kafka in java process. Hi Subhash, This would happen if `null` is passed as the `threadNamePrefix` argument when instantiating `KafkaServer`: class KafkaServer(val config: KafkaConfig, time: Time = SystemTime, threadNamePrefix: Option[String] = None) extends Logging

Re: Embedding zookeeper and kafka in java process.

g...@gmail.com] > Sent: Wednesday, June 15, 2016 3:42 PM > To: dev@kafka.apache.org > Subject: Re: Embedding zookeeper and kafka in java process. > > It seems "scala.MatchError: null" are not related to the settings that ZK > and Kafka is embedded in the same p

RE: Embedding zookeeper and kafka in java process.

in same process. It must be some kafka specific issue. Subhash Agrawal -Original Message- From: Guozhang Wang [mailto:wangg...@gmail.com] Sent: Wednesday, June 15, 2016 3:42 PM To: dev@kafka.apache.org Subject: Re: Embedding zookeeper and kafka in java process. It seems "scala.Match

Re: Embedding zookeeper and kafka in java process.

It seems "scala.MatchError: null" are not related to the settings that ZK and Kafka is embedded in the same process, and the only case that I can think of related is this: https://issues.apache.org/jira/browse/KAFKA-940. Could you clarify if you start these two services on two processes, the

Re: Embedding zookeeper and kafka in java process.

> On 15 Jun 2016, at 21:56, Subhash Agrawal wrote: > > [2016-06-15 13:39:39,808] DEBUG [ZkClient-EventThread-24-localhost:2181] > [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 > (kafka.controller.ControllerChannelManager) The controller

Embedding zookeeper and kafka in java process.

Hi All, I am embedding Kafka 0.10.0 and corresponding zookeeper in java process. In this process, I start zookeeper first and then wait for 10 seconds and then start kafka. These are all running in the same process. Toward the end of kafka startup, I see following exception. It seems zookeeper