[ https://issues.apache.org/jira/browse/FLINK-26423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jingsong Lee closed FLINK-26423. -------------------------------- Resolution: Fixed master: 7f91a853e70bb558fd2e2aa619c83558b9bccaa7 > Integrate log store to StoreSink > -------------------------------- > > Key: FLINK-26423 > URL: https://issues.apache.org/jira/browse/FLINK-26423 > Project: Flink > Issue Type: Sub-task > Components: Table Store > Reporter: Jingsong Lee > Assignee: Jingsong Lee > Priority: Major > Labels: pull-request-available > Fix For: table-store-0.1.0 > > > StoreSink is a hybrid sink. We need: > * Introduce LocalCommitterOperator, kafka can only use the same produceId > when committing, because starting multiple instances of a producer with a > single produceId is not allowed by the kafka server. So we have to reuse the > producer instance within the same process to commit. > * Committable can not be serialized, Kafka reuses producer instance in > Committable. and where the producer will not be serialized. > * Integrate log store to StoreSink. -- This message was sent by Atlassian Jira (v8.20.1#820001)