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");////////////////////////////////////////////////////////////////////////// 
value 5
                props.put("key.serializer", 
"org.apache.kafka.common.serialization.StringSerializer");
                props.put("value.serializer", 
"org.apache.kafka.common.serialization.StringSerializer");


                Producer<String, String&gt; producer = new 
KafkaProducer<&gt;(props);
                for (int i = 0; i < 1; i++) {
                        producer.send(new ProducerRecord<String, 
String&gt;("myTopic1", "key" + (i + 1), "value" + (i + 1)));
                }
                producer.close();
        }
}



console print result:

[kafka-producer-network-thread | producer-1]&nbsp;WARN 
org.apache.kafka.clients.NetworkClient -&nbsp;[Producer 
clientId=producer-1]&nbsp;Connection to node -1 (/192.168.1.113:9091) could not 
be established. Broker may not be available.
[kafka-producer-network-thread | producer-1]&nbsp;WARN 
org.apache.kafka.clients.NetworkClient -&nbsp;[Producer 
clientId=producer-1]&nbsp;Bootstrap broker 192.168.1.113:9091 (id: -1 rack: 
null) disconnected
[kafka-producer-network-thread | producer-1]&nbsp;WARN 
org.apache.kafka.clients.NetworkClient -&nbsp;[Producer 
clientId=producer-1]&nbsp;Connection to node -1 (/192.168.1.113:9091) could not 
be established. Broker may not be available.
[kafka-producer-network-thread | producer-1]&nbsp;WARN 
org.apache.kafka.clients.NetworkClient -&nbsp;[Producer 
clientId=producer-1]&nbsp;Bootstrap broker 192.168.1.113:9091 (id: -1 rack: 
null) disconnected
[main]&nbsp;INFO org.apache.kafka.clients.producer.KafkaProducer 
-&nbsp;[Producer clientId=producer-1]&nbsp;Closing the Kafka producer with 
timeoutMillis = 9223372036854775807 ms.

&nbsp;

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&nbsp;[%-5p]&nbsp;[%t]&nbsp;-&nbsp;[%l]&nbsp;%m%n

Reply via email to