Jake Maes created SAMZA-1539:
--------------------------------
Summary: KafkaProducer potential hang on close() when
task.drop.producer.errors==true
Key: SAMZA-1539
URL: https://issues.apache.org/jira/browse/SAMZA-1539
Project: Samza
Issue Type: Bug
Reporter: Jake Maes
Assignee: Jake Maes
The issue is caused by 2 bad behaviors:
1. KafkaProducer.close() does an unbounded thread.join() even when a force
close (timeout == 0 ms) is specified.
2. KafkaSystemProducer.handleSendException() has a synchronized block to
recreate the producer when task.drop.producer.errors==true. When the IO thread
is waiting on the synchronized block, it prevents the KafkaProducer from
joining the IO thread.
Fixing either one will fix the issue, but we will close this ticket as soon as
the Samza side is tested and committed.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
