Vishnu,
I think is hard to troubleshoot things without the proper context. In
your case, could you please share an example of the rows contained in
the table `sample`? As well as its DDL?
-- Ricardo
On 7/2/20 9:29 AM, vishnu murali wrote:
I go through that documentation
Where it described like DECIMAL is not supported in MySQL like this .
And also no example for MySQL so is there any other sample with MySQL
On Thu, Jul 2, 2020, 18:49 Robin Moffatt <ro...@confluent.io> wrote:
Check out this article where it covers decimal handling:
https://www.confluent.io/blog/kafka-connect-deep-dive-jdbc-source-connector/#bytes-decimals-numerics
--
Robin Moffatt | Senior Developer Advocate | ro...@confluent.io | @rmoff
On Thu, 2 Jul 2020 at 13:54, vishnu murali <vishnumurali9...@gmail.com>
wrote:
Hi Guys,
I am having some problem while reading from MySQL using JDBC source and
received like below
Anyone know what is the reason and how to solve this ?
"a": "Aote",
"b": "AmrU",
"c": "AceM",
"d": "Aote",
Instead of
"a": 0.002,
"b": 0.465,
"c": 0.545,
"d": 0.100
It's my configuration
{
"name": "sample",
"config": {
"connector.class":
"io.confluent.connect.jdbc.JdbcSourceConnector",
"connection.url": "jdbc:mysql://localhost:3306/sample",
"connection.user": "xxxx",
"connection.password": "xxx",
"topic.prefix": "dample-",
"poll.interval.ms": 3600000,
"table.whitelist": "sample",
"schemas.enable": "false",
"mode": "bulk",
"value.converter.schemas.enable": "false",
"numeric.mapping": "best_fit",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"transforms": "createKey,extractInt",
"transforms.createKey.type":
"org.apache.kafka.connect.transforms.ValueToKey",
"transforms.createKey.fields": "ID",
"transforms.extractInt.type":
"org.apache.kafka.connect.transforms.ExtractField$Key",
"transforms.extractInt.field": "ID"
}
}
