When used connector in ksqldb, some data types ex: DECIMAL, DATE (in ksqldb table) are not correct when convert value
ex:
-1,507,945.00 -> "9wMO/A=="
35,068.00 -> "NYJw"
01 DEC 2023 -> 19692
CREATE SINK CONNECTOR SINK_TRANSACTIONS_RULE01_HTTP WITH (
'connector.class' = 'io.aiven.kafka.connect.http.HttpSinkConnector',
'http.url' = 'https://webhook.site/6d74bf60-f754-4f57-b1ee-8eed9208b9ea',
'http.authorization.type' = 'none',
'topics' = 'ksql_transactions_rule01',
'key.converter' = 'io.confluent.connect.avro.AvroConverter',
'key.converter.schema.registry.url' = 'http://localhost:8081',
'value.converter' = 'io.confluent.connect.avro.AvroConverter',
'value.converter.schema.registry.url' = 'http://localhost:8081',
'batching.enabled' = 'true',
'batch.max.size' = 2,
'tasks.max' = '1'
);
When used connector in ksqldb, some data types ex: DECIMAL, DATE (in ksqldb table) are not correct when convert value
ex:
-1,507,945.00 -> "9wMO/A=="
35,068.00 -> "NYJw"
01 DEC 2023 -> 19692