Thanks Jun.
My build has not included that fix. I'll try out the latest 0.8.2
On Sat Jan 24 2015 at 上午1:47:40 Jun Rao wrote:
> Are you on the latest 0.8.2 branch? We did fix KAFKA-1738 a couple of
> months ago which could prevent new topics from created.
>
> Thanks,
>
> Jun
>
> On Thu, Jan 22,
Are you on the latest 0.8.2 branch? We did fix KAFKA-1738 a couple of
months ago which could prevent new topics from created.
Thanks,
Jun
On Thu, Jan 22, 2015 at 9:44 PM, Manu Zhang wrote:
> Hi all ,
> My application creates kafka topic at runtime with AdminUtils.createTopic
> but that topic i
Manu,
Are you passing ZkStringSerializer to zkClient .
ZkClient zkClient = new ZkClient(ZK_CONN_STRING,3, 3, new
ZkStringSerializer());
AdminUtils.createTopic(zkClient, topic, 1, 1, props);
-Harsha
On Thu, Jan 22, 2015, at 09:44 PM, Manu Zhang wrote:
> Hi all ,
> My application creat
Hi all ,
My application creates kafka topic at runtime with AdminUtils.createTopic
but that topic is not available when I try to produce to it.
If I run "bin/kafka-console-consumer.sh --topic $topic --zookeeper $zkStr
--from-beginning" it would throw UnknownTopicOrPartitionException.
Also, I fou
