-
hi,
I am trying to use the CamelHttpsSinkConnector to fulfill that sync the Kafka events to the remote Endpoint.
The remote endpoint URL accessing must by MTLS need to set keystore information.
…
-
- [x] 我已经在 [issues](https://github.com/didi/KnowStreaming/issues) 搜索过相关问题了,并没有重复的。
## deployment部署的knowstreaming,接入statefulset部署的kafka集群提示超时
```
[root@k8s-master-01:~] # kubectl get pod -n knowst…
-
`org.apache.kafka.common.config.ConfigException: Unknown configuration 'sqs.message.attributes.partition.key'
at org.apache.kafka.common.config.AbstractConfig.get(AbstractConfig.java:162)
at…
-
### Feature or Problem Description
When using Debezium + Registry, the converter/connector produces messages on the Kafka topic in a specific format. This format includes the schemaId and the payloa…
-
### Windows Version
10.0.22635.3430
### WSL Version
2.2.1.0
### Are you using WSL 1 or WSL 2?
- [x] WSL 2
- [ ] WSL 1
### Kernel Version
5.15.150.1
### Distro Version
Ubu…
-
I am trying to send nested JSON messages and sink them using Kafka connect S3sink to parque.
Whenever I nest the object too much the connector gives me the error message below.
```md
org.apache.k…
-
Hi folks,
Thanks for the work on maintaining the project. Recently I've had to migrate a project away from Akka due to the license change and the Pekko project was a life saver!
The latest packa…
-
This is a similar report to https://github.com/tabular-io/iceberg-kafka-connect/issues/231: we see these task failures frequently, often daily or weekly. Rather than request more configuration paramet…
-
**Describe the bug**
Schema Inference With ID in CSAS does not work for enums.
**To Reproduce**
To reproduce
Register below schema for topic avroTest4
```
{
"doc": "Sample schema to help y…
-
Snowflake connector does not accept connection properties in snowflake URL: https://github.com/snowflakedb/snowflake-kafka-connector/blob/4d358495ea172244ede28c42c39fb20b559f1fad/src/main/java/com/sno…