Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Purpose
Fixes #1085.
Previously, the
FileStreamProtocol
required another sink (SendToBrokerReplayAdapterSink
) for the adapter preprocessing pipeline.The reason for this was that the
FileStreamProtocol
needs to adjust the timestamp for correct replay, but it was the only adapter / protocol that used a different sink.The
SendToBrokerReplayAdapterSink
class was deleted and the code was moved directly to theFileStreamProtocol
.Further, some minor refactoring was performed.
This should not be the final rewrite of the protocol, it is just a clean up step to better refactor the connect api.
Remarks
PR introduces (a) breaking change(s): no
PR introduces (a) deprecation(s): no