[
https://issues.apache.org/jira/browse/KAFKA-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077832#comment-17077832
]
Jordan Moore commented on KAFKA-9822:
-------------------------------------
If you are looking for support, this question would be better suited for
StackOverflow.
Besides, You have failed to mention your OS, Java version, Kafka version, etc.
> java kafka-client use "props.put("retries", "5")" ,why print 2 log ? Should 6
> log !
> -----------------------------------------------------------------------------------
>
> Key: KAFKA-9822
> URL: https://issues.apache.org/jira/browse/KAFKA-9822
> Project: Kafka
> Issue Type: Test
> Reporter: startjava
> Priority: Major
>
> package test2;package test2;
> import java.util.Properties;
> import org.apache.kafka.clients.producer.KafkaProducer;import
> org.apache.kafka.clients.producer.Producer;import
> org.apache.kafka.clients.producer.ProducerRecord;
> public class ProduceMessage { public static void main(String[] args) {
> Properties props = new Properties();
> props.put("bootstrap.servers", "192.168.1.113:9091");/////////////wrong ip
> address
> props.put("acks", "1");
> props.put("retries", "5");
> props.put("key.serializer",
> "org.apache.kafka.common.serialization.StringSerializer");
> props.put("value.serializer",
> "org.apache.kafka.common.serialization.StringSerializer");
> Producer<String, String> producer = new KafkaProducer<>(props);
> for (int i = 0; i < 1; i++) {
> producer.send(new ProducerRecord<String, String>("myTopic1", "key" + (i + 1),
> "value" + (i + 1))); } producer.close(); }}
>
> console print result:
> [kafka-producer-network-thread | producer-1] WARN
> org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1]
> Connection to node -1 (/192.168.1.113:9091) could not be established. Broker
> may not be available.
> [kafka-producer-network-thread | producer-1] WARN
> org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1]
> Bootstrap broker 192.168.1.113:9091 (id: -1 rack: null) disconnected
> [kafka-producer-network-thread | producer-1] WARN
> org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1]
> Connection to node -1 (/192.168.1.113:9091) could not be established. Broker
> may not be available.
> [kafka-producer-network-thread | producer-1] WARN
> org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1]
> Bootstrap broker 192.168.1.113:9091 (id: -1 rack: null) disconnected
> [main] INFO org.apache.kafka.clients.producer.KafkaProducer - [Producer
> clientId=producer-1] Closing the Kafka producer with timeoutMillis =
> 9223372036854775807 ms.
>
>
> log4j.properties:
> log4j.rootLogger=INFO,console
> log4j.logger.com.demo.kafka=DEBUG,kafka
> log4j.appender.kafka=kafka.producer.KafkaLog4jAppender
> log4j.appender.console=org.apache.log4j.ConsoleAppender
> log4j.appender.console.target=System.out
> log4j.appender.console.layout=org.apache.log4j.PatternLayout
> log4j.appender.console.layout.ConversionPattern=%d [%-5p] [%t] - [%l] %m%n
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
