Sink API drops messages when there is no connectivity with Kafka

Description

When pushing messages to Kafka, Sink API  drops any messages after default timeout (max.block.ms = 60000, producer config) expires.  It should block till it can deliver the message.

Acceptance / Success Criteria

None

Lucidchart Diagrams

Activity

Show:

Chandra Gorantla November 2, 2018 at 6:12 PM

Fixed

Details

Assignee

Reporter

Sprint

Priority

PagerDuty

Created October 4, 2018 at 11:36 PM
Updated November 8, 2018 at 3:27 PM
Resolved November 7, 2018 at 3:21 AM