onfig); with kafka 0.10.0? if not,
> > how can I pass
> > these 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 Ismae
fka 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: Embedding zookeeper and kafka in ja
: 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
nesday, 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 process, and the only case that I can
&
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
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
issue
> 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 isn't being able to con