Hi Jun ,
I made such tests:
*bin/kafka-console-producer.sh --zookeeper localhost:2181 --topic test
*
This is a message
This is another message
*> bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic
test --from-beginning*
This is a message
This is another message
and it works fine.
Is there any other tests should I do to be sure that kafka broker works fine?
Thanks
Oleg.
On Tue, Jul 23, 2013 at 11:14 AM, Jun Rao <jun...@gmail.com> wrote:
> Those exception are ok since they are at the info level. Is the broker
> running ok otherwise?
>
> Thanks,
>
> Jun
>
>
> On Tue, Jul 23, 2013 at 7:46 AM, Oleg Ruchovets <oruchov...@gmail.com
> >wrote:
>
> > Hi All.
> >
> > I have on one machine kafka installation. I needed to move it to
> another
> > machine and I copied a kafka folder to that machine.
> >
> > when I started kafka in new machine I got such output:
> >
> > [2013-07-23 17:03:29,858] INFO Got user-level KeeperException when
> > processing sessionid:0x1400bd6e2960000 type:create cxid:0x1
> > zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error
> Path:/brokers/ids
> > Error:KeeperErrorCode = NoNode for /brokers/ids
> > (org.apache.zookeeper.server.PrepRequestProcessor)
> > [2013-07-23 17:03:29,872] INFO Got user-level KeeperException when
> > processing sessionid:0x1400bd6e2960000 type:create cxid:0x2
> > zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/brokers
> > Error:KeeperErrorCode = NoNode for /brokers
> > (org.apache.zookeeper.server.PrepRequestProcessor)
> > [2013-07-23 17:03:29,886] INFO Registering broker /brokers/ids/0
> succeeded
> > with
> id:0,creatorId:172.31.202.2-1374588209838,host:172.31.202.2,port:9092
> > (kafka.server.KafkaZooKeeper)
> > [2013-07-23 17:03:29,907] INFO Starting log flusher every 1000 ms with
> the
> > following overrides Map() (kafka.log.LogManager)
> > [2013-07-23 17:03:29,909] INFO Kafka server started.
> > (kafka.server.KafkaServer)
> > [2013-07-23 17:15:35,903] INFO Accepted socket connection from
> > /0:0:0:0:0:0:0:1:45710 (org.apache.zookeeper.server.NIOServerCnxn)
> > [2013-07-23 17:15:35,906] INFO Client attempting to establish new session
> > at /0:0:0:0:0:0:0:1:45710 (org.apache.zookeeper.server.NIOServerCnxn)
> > [2013-07-23 17:15:35,909] INFO Established session 0x1400bd6e2960001 with
> > negotiated timeout 6000 for client /0:0:0:0:0:0:0:1:45710
> > (org.apache.zookeeper.server.NIOServerCnxn)
> > [2013-07-23 17:35:19,019] INFO Created log for 'topic1'-0
> > (kafka.log.LogManager)
> > [2013-07-23 17:35:19,023] INFO Begin registering broker topic
> > /brokers/topics/topic1/0 with 1 partitions (kafka.server.KafkaZooKeeper)
> > [2013-07-23 17:35:19,024] INFO Got user-level KeeperException when
> > processing sessionid:0x1400bd6e2960000 type:create cxid:0x6
> > zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error
> > Path:/brokers/topics/topic1 Error:KeeperErrorCode = NoNode for
> > /brokers/topics/topic1 (org.apache.zookeeper.server.PrepRequestProcessor)
> > [2013-07-23 17:35:19,032] INFO End registering broker topic
> > /brokers/topics/topic1/0 (kafka.server.KafkaZooKeeper)
> >
> >
> > It actually make sense getting exception related to the
> > "Path:/brokers/ids".
> >
> > Questions:
> > What should I do to fix the problem on my new machine? Is there and
> way
> > to cleanup kafka on new machine ?
> >
> > Thanks
> > Oleg.
> >
>
