Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4239
Thanks a lot for opening a pull request for this very important feature
@pnowojski.
I did a rough first pass and had some comments I would like to clear out
first (this is a big chunk of code, we would probably need to go through this
quite a few times before it can be mergeable.)
Most notably, some comments so far:
1. I think we need UTs for the `TwoPhaseCommitSinkFunction`. It alone is a
very important addition (I would even prefer a separate PR for it and try to
merge that first.)
2. Serialization of the transaction state in `TwoPhaseCommitSinkFunction`
needs to be changed
2. Is the `FlinkKafkaProducer011` actually supporting hybrid (normal sink
function and `writeToKafkaWithTimestamps` as a custom sink operator)? From the
looks of it, it doesn't seem like it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
