Details
-
Bug
-
Resolution: Fixed
-
Major
-
None
-
None
-
1
Description
Conductor.maybeMovePartition was unconditionally published a FailedToMovePartitionEvent whenever the move failed, even it failed due to rollback (which is recoverable).
Since FailedToMovePartitionEvent is a subclass of DcpFailureEvent, EventHandlerAdapter treats it as a fatal error and dispatches it to the StreamError callback method, leading to the connector shutdown in KAFKAC-211.
Proposed fix is for Conductor.maybeMovePartition to publish the FailedToMovePartitionEvent only if the failure was not due to rollback.
Attachments
Issue Links
- blocks
-
KAFKAC-211 Source: Rollback causes connector to terminate
- Resolved