silent-night-no-trace commented on issue #9899:
URL: https://github.com/apache/seatunnel/issues/9899#issuecomment-3341330643
I specified the serialization and deserialization classes for the Kafka
configuration and everything seems to be working fine.
But if it is not specified, it will prompt that the class does not exist.
This should be a bug
forexample
```conf
sink {
kafka {
topic = "user_topic"
bootstrap.servers =
"192.168.109.211:9092,192.168.109.212:9092,192.168.109.213:9092"
format = json
kafka.request.timeout.ms = 60000
kafka.config = {
acks = "all"
request.timeout.ms = 60000
buffer.memory = 33554432
key.serializer =
"org.apache.kafka.common.serialization.StringSerializer"
value.serializer =
"org.apache.kafka.common.serialization.StringSerializer"
}
}
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
