pushpavanthar
pushpavanthar
Added support to Automatically exclude MySQL tables on RDS based on Replicate_Ignore_Table
This PR contains changes for numeric.mapping config to support both NUMERIC and DECIMAL fields. It resolves open issues [563](https://github.com/confluentinc/kafka-connect-jdbc/issues/563) and [311](https://github.com/confluentinc/kafka-connect-jdbc/issues/311).
Problem: When DeltaStreamer running in continuous mode is killed and resumed, below error is thrown. ``` 23/01/12 13:28:06 ERROR HoodieAsyncService: Service shutdown with error java.util.concurrent.ExecutionException: org.apache.hudi.exception.HoodieRollbackException: Failed to rollback s3://datalake_bucket/test/hudi_poc/continuous_cow/loan_applications...
The Scylladb sink connector works fine when "`scylladb.offset.storage.table.enable`" is set to `true` (when consumer group offset is maintained in scylladb table). However, when this config is set to `false` (consumer...
The connector fails with the below exception when mapping is provided with different topic and table names. It doesn't pick the table name from the mapping config `topic.my_topic.my_ks.my_table.mapping`. Whereas datastax...
The Connector fails to start when `"scylladb.ttl"` config is set. There seems to be casting exception due to datatype of `ttl` in `io.connect.scylladb.ScyllaDbSinkConnectorConfig.class`. The below exception is observed when a...
## Problem Field Partitioner could not pick value if the incoming record is of the form of map ## Solution Handled to fetch attribute value when the payload of Map...