Currently the two phase commit support is added for all the drivers full refresh, incremental and cdc mode wherever supported, The same needs to be implemented for kafka as well
|
// TODO: Add 2PC support for Kafka (difficulty: hard) |
|
|
|
func (k *Kafka) ChangeStreamConfig() (bool, bool, bool) { |
|
return false, true, false // parallel change streams supported |
|
} |
This issue was generated by todo-issue based on a TODO comment in 2c441eb. It's been assigned to @vaibhav-datazip because they committed the code.
Currently the two phase commit support is added for all the drivers full refresh, incremental and cdc mode wherever supported, The same needs to be implemented for kafka as well
olake/drivers/kafka/internal/cdc.go
Lines 21 to 25 in 2c441eb
This issue was generated by todo-issue based on a
TODOcomment in 2c441eb. It's been assigned to @vaibhav-datazip because they committed the code.