*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 <mmistr...@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 <
> deshpandesh...@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
>>
>
>
