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> 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