Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Plain View
Kafka >> mail # user >> clean up kafka environmet


+
Oleg Ruchovets 2013-07-23, 14:47
+
Jun Rao 2013-07-23, 15:14
+
Oleg Ruchovets 2013-07-23, 15:45
Copy link to this message
-
Re: clean up kafka environmet
Changed my tests with different consuming groups but still have the same
logs with Error:

[2013-07-23 19:25:19,439] INFO Got user-level KeeperException when
processing sessionid:0x1400bd6e296000c type:create cxid:0x15
zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error
Path:/consumers/group12/owners Error:KeeperErrorCode = NoNode for
/consumers/group12/owners (org.apache.zookeeper.server.PrepRequestProcessor)
[2013-07-23 19:25:19,439] INFO Got user-level KeeperException when
processing sessionid:0x1400bd6e296000b type:create cxid:0x15
zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error
Path:/consumers/group10/owners Error:KeeperErrorCode = NoNode for
/consumers/group10/owners (org.apache.zookeeper.server.PrepRequestProcessor)

Question: What does these Errors means? I have no such exception on the
previous machine. How to configure kafka to fix it?

Thanks
Oleg.

On Tue, Jul 23, 2013 at 11:44 AM, Oleg Ruchovets <[EMAIL PROTECTED]>wrote:

> 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 <[EMAIL PROTECTED]> 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 <[EMAIL PROTECTED]
>> >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

 
+
Neha Narkhede 2013-07-23, 16:36
+
Neha Narkhede 2013-07-23, 16:39
+
Oleg Ruchovets 2013-07-23, 16:54
+
Oleg Ruchovets 2013-07-23, 17:27
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB