Aiven-Open / Aiven-Open/http-connector-for-apache-kafka

Wrong type converter with Avro format

Aperta
#214 1 commento 0 reazioni 0 assegnatari Vedi su GitHub
Lingua principale
Java
Stelle
119
Fork
63
Metriche di merge delle PR
Nessuna PR unita negli ultimi 30g

Descrizione

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'
);
```

Guida per i contributori

Nessuna guida per i contributori indicizzata per questo repository

Valutazione

Questa issue non è ancora stata valutata.

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.