Anyone has idea? Thank you
Sent from my iPhone
> On Sep 30, 2014, at 1:45 PM, Jiang Jacky wrote:
>
> Hi, Guys
> It is very weird, I created a topic with 2 partitions couple weeks ago, and I
> can only production the message to partition 0, not partition 1, but for now,
&g
Hi, Guys
It is very weird, I created a topic with 2 partitions couple weeks ago, and
I can only production the message to partition 0, not partition 1, but for
now, I created a new topic again with 2 partitions, it does work.
So whats problem of the old topic? I tried to describe the old topic, I
f
issue? I have opened all ports of my
machine at my home, and the security group is also opened for kafka server
and zookeeper in EC2. Everything is fine, but I just cannot send any
message to kafka server.
Please help me.
Thanks Everyone!
Jacky
ld be opened for kafka server?
Thanks
2013/10/5 Guozhang Wang
> Hello Jacky,
>
> Have you read this FAQ:
>
>
> https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-OnEC2%2Cwhycan%27tmyhighlevelconsumersconnecttothebrokers%3F
>
> Guozhang
>
>
> On Fri, Oct 4
Hi, I run into kafka issue recently, when I try to produce a message, it
gives me follow error
[2013-10-11 00:30:26,740] INFO Fetching metadata from broker
id:0,host:localhost,port:9092 with correlation id 47 for 1 topic(s)
Set(my-replicated-topic) (kafka.client.ClientUtils$)
[2013-10-11 00:30:26,
can anyone help me? Thanks a lot
2013/10/10 Jiang Jacky
> Hi, I run into kafka issue recently, when I try to produce a message, it
> gives me follow error
>
> [2013-10-11 00:30:26,740] INFO Fetching metadata from broker
> id:0,host:localhost,port:9092 with correlation id 4
yes, even I cannot create new topic, same error, leadernotavailable.
My zookeeper and storm all are working very well, except of Kafka.
2013/10/10 Neha Narkhede
> Are you trying to produce these messages to a newly created topic?
>
>
> On Thu, Oct 10, 2013 at 6:15 PM, Jiang
Another thing need is my instance comes with very small memory, just 683M,
I am not sure if it is related. I will try to use 8G memory instance.
2013/10/10 Jiang Jacky
> yes, even I cannot create new topic, same error, leadernotavailable.
> My zookeeper and storm all are working ver
did anyone experience same issue? can you share with me?
Thanks a lot.
2013/10/7 Jun Rao
> Kafka port is documented in
> http://kafka.apache.org/documentation.html#brokerconfigs
>
> Thanks,
>
> Jun
>
>
> On Sat, Oct 5, 2013 at 12:05 PM, Jiang Jacky wrote:
>
Hi, Everyone, I use the larger memory instance to replace that small one,
for now, I can create the topic, but when I try to produce message, it
still gives the same error.
Its so weird. can any one help me? Thanks
2013/10/10 Jiang Jacky
> Another thing need is my instance comes with v
*Hi, Guys,*
*I am currently running into the kafka server issue. *
*I have a 5 nodes cluster and zookeeper running without any problem. when I
manually boot each node by using* "*JMX_PORT=9997 bin/kafka-server-start.sh
config/server-x.properties &*" command.
*The scenario is:*
*Then, first node, i
/mail/ca/u/0/#label/TechDiscuss/141a5c074641dd70
Please have a look. Thanks a lot.
2013/10/11 Aniket Bhatnagar
> Hi Jiang
>
> Just thinking out loud, it could be because Kafka can't connect to
> Zookeeper. Can you check Kafka logs to validate the same?
>
>
> On 11 Octob
?
>
> Thanks,
>
> Jun
>
>
> On Thu, Oct 10, 2013 at 9:22 PM, Jiang Jacky wrote:
>
> > *Hi, Guys,*
> > *I am currently running into the kafka server issue. *
> > *I have a 5 nodes cluster and zookeeper running without any problem.
> when I
> > manua
elps ..
>
> -Joe
>
> Sent from my Droid Charge on Verizon 4G LTE Jiang Jacky wrote:
> did anyone experience same issue? can you share with me?
> Thanks a lot.
>
>
> 2013/10/7 Jun Rao
>
> > Kafka port is documented in
> > http://kafka.apache.org/documentation
Thanks Jun Rao
Where can I find those logs?
2013/10/11 Jun Rao
> Any error in the controller and state-change log?
>
> Thanks,
>
> Jun
>
>
> On Thu, Oct 10, 2013 at 9:38 PM, Jiang Jacky wrote:
>
> > Hi, Aniket
> > Thanks for your reply
> > I checke
Yes, everytime, I send message, it throws that error.
2013/10/11 Jun Rao
> Is that reproducible?
>
> Thanks,
>
> Jun
>
>
> On Thu, Oct 10, 2013 at 9:54 PM, Jiang Jacky wrote:
>
> > Yes, it just says "INFO Reconnect due to socket error"
> > But
Sorry, even I don't send message, it shows up that message about every 1
minute
2013/10/11 Jiang Jacky
> Yes, everytime, I send message, it throws that error.
>
>
> 2013/10/11 Jun Rao
>
>> Is that reproducible?
>>
>> Thanks,
>>
>> Jun
>
no, it is not reproducible. Thank you.
2013/10/11 Jun Rao
> I meant the broker crash. Is that reproducible?
>
> Thanks,
>
> Jun
>
>
> On Thu, Oct 10, 2013 at 10:10 PM, Jiang Jacky wrote:
>
> > Yes, everytime, I send message, it throws that error.
> >
&
-11 05:32:42,710] INFO Closing socket connection to /10.0.0.42.
(kafka.network.Processor)
2013/10/11 Jiang Jacky
> no, it is not reproducible. Thank you.
>
>
> 2013/10/11 Jun Rao
>
>> I meant the broker crash. Is that reproducible?
>>
>> Thanks,
>>
>&g
Ok, finally, I find the problem, in the /etc/hosts, I set the hostname as
127.0.0.1 ip-10-0-0-108
It seems cannot use its internal hostname, and caused the connection to
close.
Thanks guys, if I encounter any further issue, I will let you know.
2013/10/11 Jiang Jacky
> Hi, Since I changed
Hi, Everyone
For now, I have a kafka cluster, and there is only 1 partition in each
node. i just also produce lots of messages to 1 topic only.
Then, I have a problem, I used it for a while, the topic is crashed, the
error message is "NoAvailableLeader", but it is good for other topics that
I do no
on? It is
> important to figure out the root cause of NoAvailableLeader, but it is
> transient and should fix itself. Are you using 0.8 HEAD ?
>
>
> On Tue, Oct 29, 2013 at 5:57 PM, Jiang Jacky wrote:
>
> > Hi, Everyone
> > For now, I have a kafka cluster, and there is
to use a higher replication factor.
>
> Thanks,
> Neha
>
>
> On Thu, Oct 31, 2013 at 12:07 PM, Jiang Jacky wrote:
>
> > Hi, Neha
> > Thanks for replying, I am currently using the 0.8 version.
> > I did not set any replication factor, it keeps the default fr
, nothing is working.
https://github.com/mapr-demos/kafka-sample-programs
Have configured all the parameter from the *.props files.
Thanks
Jacky
24 matches
Mail list logo
