[
https://issues.apache.org/jira/browse/KAFKA-7111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16526405#comment-16526405
]
Stanislav Kozlovski commented on KAFKA-7111:
--------------------------------------------
[~lcestari] I followed the instructions on the
[README|https://github.com/confluentinc/cp-docker-images/blob/master/docs/installation/recipes/single-node-client.rst]
Up until Step 4. I then attached to the kafka broker and killed it while the
producer was running. That resulted in the following exception:
{code}
[2018-06-28 14:58:56,007] ERROR Error when sending message to topic bar with
key: null, value: 12 bytes with error:
(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback:52)
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for
bar-0: 1510 ms has passed since batch creation plus linger time
[2018-06-28 14:58:56,007] ERROR Error when sending message to topic bar with
key: null, value: 12 bytes with error:
(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback:52)
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for
bar-0: 1510 ms has passed since batch creation plus linger time
{code}
I then restarted the producer (with no running broker to connect to) and that
resulted in this:
{code}
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:459)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:304)
at kafka.producer.NewShinyProducer.<init>(BaseProducer.scala:40)
at kafka.tools.ConsoleProducer$.main(ConsoleProducer.scala:49)
at kafka.tools.ConsoleProducer.main(ConsoleProducer.scala)
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable
bootstrap urls given in bootstrap.servers
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:66)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:407)
... 4 more
{code}
Did you use another image? Could you please point me more specifically how to
reproduce this, maybe even share some code? I'd like to get to the bottom of
this.
Otherwise - could you be swallowing some exception in your Java client?
> Review the NetworkClient log level used
> ---------------------------------------
>
> Key: KAFKA-7111
> URL: https://issues.apache.org/jira/browse/KAFKA-7111
> Project: Kafka
> Issue Type: Improvement
> Components: clients
> Reporter: Luan Cestari
> Assignee: Stanislav Kozlovski
> Priority: Trivial
>
> Hi,
>
> I was using Kafka on some projects and unfortunately I had to use Debug (and
> some times even Trace) log level to see some issues. One of the most recently
> cases was:
> [https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java#L872]
>
> If I got the name of the broker and it is unreachable, the errors should be
> more severe than "DEBUG" level IMHO. I would at least put a INFO level for
> this case or ERROR level (which seems to fit better but I don't know the
> practices used in the project).
>
> Thank you in advance
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)