[ https://issues.apache.org/jira/browse/KAFKA-4109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Manikumar resolved KAFKA-4109. ------------------------------ Resolution: Cannot Reproduce Pl reopen if you think the issue still exists > kafka client send msg exception > ------------------------------- > > Key: KAFKA-4109 > URL: https://issues.apache.org/jira/browse/KAFKA-4109 > Project: Kafka > Issue Type: Bug > Components: producer > Affects Versions: 0.10.0.0 > Environment: java8 > kafka cluster > Reporter: frank > Original Estimate: 5m > Remaining Estimate: 5m > > java.util.concurrent.ExecutionException: > org.apache.kafka.common.errors.TimeoutException: Batch Expired > at > org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:56) > > at > org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:43) > > at > org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:25) > > at > com.longsheng.basicCollect.kafka.KafkaProducer.publishMessage(KafkaProducer.java:44) > > at > com.longsheng.basicCollect.crawler.processor.dzwbigdata.ParentBasic.publish(ParentBasic.java:60) > > at > com.longsheng.basicCollect.crawler.processor.dzwbigdata.ParentBasic.parseIncJson(ParentBasic.java:119) > > at > com.longsheng.basicCollect.crawler.processor.dzwbigdata.coke.price.SecondPrice.collectData(SecondPrice.java:41) > > at > com.longsheng.basicCollect.crawler.processor.dzwbigdata.coke.price.SecondPrice.process(SecondPrice.java:49) > > at > com.longsheng.basicCollect.crawler.processor.dzwbigdata.DzwProcessor.process(DzwProcessor.java:33) > > at > com.longsheng.basicCollect.timer.CollectDzwBigData.execute(CollectDzwBigData.java:14) > > at org.quartz.core.JobRunShell.run(JobRunShell.java:202) > at > org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:573) > Caused by: org.apache.kafka.common.errors.TimeoutException: Batch Expired > the exception is arbitrarily! -- This message was sent by Atlassian JIRA (v6.4.14#64029)