you are right.
after I run kafka in my localhost directly, it works just fine
after further google, i found that need to set two parameters below if the
kafka is running on some other machines
#advertised.host.name=
#advertised.port=
more precisely, if the kafka is running within a docker conta
Some suggestions:
Check the existence of the topic.
Check the firewall of the broker... Try telnet or something to
make sure it's available.
Try run the producer on the broker machine.
Since you get this error, this code is functioning. I think it's some
configuration an
Hi I have a very simple code to just send out one message, the topic is
created automatically, but the message just cannot be sent out. I also
tried to change the configuration, the result is still the same. Sorry to
bother you all with this silly question.
For your information, the kafka server i
ifiableProperties).
> log4j:WARN Please initialize the log4j system properly.
> log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for
> more info.
> Exception in thread "main" kafka.common.FailedToSendMessageException:
> Failed to send
ogger
(kafka.utils.VerifiableProperties).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more
info.
Exception in thread "main" kafka.common.FailedToSendMessageException: Failed to
send messages after 3 trie
gt; a "pilot error" :-) The snippet you provided doesn't seem to have this
> >>> problem, but it is interesting that we got the same error (which would
> >>>be
> >>> nice if it can be customized depending on the actual problem
7;s host and port). In other
>>>words
>>> a "pilot error" :-) The snippet you provided doesn't seem to have this
>>> problem, but it is interesting that we got the same error (which would
>>>be
>>> nice if it can be customized depending on the actual probl
ogesh.sangvi...@gmail.com>:
>
> > Hi Jun,
> >
> > The stack trace we found is as follow,
> >
> > log4j:WARN No appenders could be found for logger
> > (kafka.utils.VerifiableProperties).
> > log4j:WARN Please initialize the log4j system properly.
>
d be found for logger
> (kafka.utils.VerifiableProperties).
> log4j:WARN Please initialize the log4j system properly.
> kafka.common.FailedToSendMessageException: Failed to send messages after 3
> tries.
> at
>
> kafka.producer.async.DefaultEventHandler.handle(
or" :-) The snippet you provided doesn't seem to have this
> >> problem, but it is interesting that we got the same error (which would
> be
> >> nice if it can be customized depending on the actual problem: host
> >> unreachable, not responding,
never the less the message was enqueued
>> >four times into the cluster. It would be great to get any hint on this
>> >issue.
>> >
>> >regards
>> >
>> >--
>> >Markus Roder
>> >
>> >Am 25.06.2013 um 07:18 schrieb Yog
er. It would be great to get any hint on this
> >issue.
> >
> >regards
> >
> >--
> >Markus Roder
> >
> >Am 25.06.2013 um 07:18 schrieb Yogesh Sangvikar
> >:
> >
> >> Hi Jun,
> >>
> >> The
>:
>
>> Hi Jun,
>>
>> The stack trace we found is as follow,
>>
>> log4j:WARN No appenders could be found for logger
>> (kafka.utils.VerifiableProperties).
>> log4j:WARN Please initialize the log4j system properly.
>> kafka.common.Failed
> log4j:WARN No appenders could be found for logger
> (kafka.utils.VerifiableProperties).
> log4j:WARN Please initialize the log4j system properly.
> kafka.common.FailedToSendMessageException: Failed to send messages after 3
> tries.
>at
> kafka.producer
Hi Jun,
The stack trace we found is as follow,
log4j:WARN No appenders could be found for logger
(kafka.utils.VerifiableProperties).
log4j:WARN Please initialize the log4j system properly.
kafka.common.FailedToSendMessageException: Failed to send messages after 3
tries.
at
Could you attach the log before FailedToSendMessageException in the
producer? It should tell you the reason why the message can't be sent.
Thanks,
Jun
On Mon, Jun 24, 2013 at 9:20 PM, Yogesh Sangvikar <
yogesh.sangvi...@gmail.com> wrote:
> Hi Team,
>
> We are using kafka-0.8.0-beta1-candidate
Hi Team,
We are using kafka-0.8.0-beta1-candidate1 release. (
https://github.com/apache/kafka/tree/0.8.0-beta1-candidate1).
While running producer with following configuration, we found an issue
"kafka.common.
FailedToSendMessageException: Failed to send messages after 3 tries",
We are using def
17 matches
Mail list logo
