You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@spark.apache.org by shyla deshpande <de...@gmail.com> on 2017/02/28 22:23:34 UTC

error in kafka producer

producer send callback exception:
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for
positionevent-6 due to 30003 ms has passed since batch creation plus linger
time

Re: error in kafka producer

Posted by shyla deshpande <de...@gmail.com>.

*My code:*

      producer.send(message, new Callback {
        override def onCompletion(metadata: RecordMetadata, exception:
Exception): Unit = {
          log.info(s"producer send callback metadata: $metadata")
          log.info(s"producer send callback exception: $exception")
        }
      })

*Error Message :*

producer send callback metadata: null
producer send callback exception:
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s)
for positionevent-1 due to 30024 ms has passed since batch creation
plus linger time



On Tue, Feb 28, 2017 at 3:15 PM, Marco Mistroni <mm...@gmail.com> wrote:

> This exception coming from a Spark program?
> could you share few lines of code ?
>
> kr
>  marco
>
> On Tue, Feb 28, 2017 at 10:23 PM, shyla deshpande <
> deshpandeshyla@gmail.com> wrote:
>
>> producer send callback exception: org.apache.kafka.common.errors.TimeoutException:
>> Expiring 1 record(s) for positionevent-6 due to 30003 ms has passed since
>> batch creation plus linger time
>>
>
>

Re: error in kafka producer

Posted by Marco Mistroni <mm...@gmail.com>.

This exception coming from a Spark program?
could you share few lines of code ?

kr
 marco

On Tue, Feb 28, 2017 at 10:23 PM, shyla deshpande <de...@gmail.com>
wrote:

> producer send callback exception: org.apache.kafka.common.errors.TimeoutException:
> Expiring 1 record(s) for positionevent-6 due to 30003 ms has passed since
> batch creation plus linger time
>