Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for topic_test_1219-2: 30010 ms has passed since batch creatio

时间：2021-06-11 14:34:11

代码如下

 public static void producer1() throws ExecutionException, InterruptedException {

        Properties props = new Properties();

        props.put("bootstrap.servers", "xxx:9092,xxx:9092,xxx:9092");

        props.put("zookeeper.connect", "xxx:2181,xxx:2181,xxx:2181");

        props.put("acks", "all");

        props.put("retries", );

        props.put("batch.size", );

        props.put("linger.ms", );

        props.put("buffer.memory", );

        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<String, String>(props);

        for (int i = ; i < ; i++) {

            System.out.println(i);

            Future<RecordMetadata> future = producer.send(new ProducerRecord<String, String>("topic_test_1219", Integer.toString(i), Integer.toString(i)));

            System.out.println("partiton:" +  future.get().partition() + ",offset:" + future.get().offset() + ",isDone:" + future.isDone());

        }

        producer.close();

    }

错误如下

Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for topic_test_1219-2: 30010 ms has passed since batch creation plus linger time

	at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:94)

	at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:64)

	at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:29)

	at com.zhen.kafka.ProducerTest.producer1(ProducerTest.java:38)

	at com.zhen.kafka.ProducerTest.main(ProducerTest.java:18)

Caused by: org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for topic_test_1219-2: 30010 ms has passed since batch creation plus linger time

　　折腾许久，原来是域名解析问题，记得本地hosts中配一下kafka服务所在机器的IP

相关文章