*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")
}
}
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
wrote:
> producer send callback exception:
> org.apache.kafka.common.errors.TimeoutException:
> Expiring 1 record(s) for positionevent-6 due to 30003 ms h
