Replies: 2 comments 3 replies
-
If I set the Version as 3.8.0 I get the following error, as it is not compatible.
|
Beta Was this translation helpful? Give feedback.
2 replies
-
Thanks for the reply. I do know there was some api change between 3.8.0 and 3.9.0 kafka connect api. |
Beta Was this translation helpful? Give feedback.
1 reply
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
Bug Description
I have a image build on top of strimzi like below to package my plugins, when i deploy it with strimzi operator 0.46.1 I get an error and it goes into crash loopback. It works fine if I build it using 0.46.1 image.
Is this by design or is it a bug? Meaning Kafka-Connect images are not compatible from version to version?
error:
2025-07-17 07:57:58,349 ERROR Stopping due to error (org.apache.kafka.connect.cli.AbstractConnectCli) [main] org.apache.kafka.common.config.ConfigException: Missing required configuration "key.converter" which has no default value. at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:534) at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:524) at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:114) at org.apache.kafka.connect.runtime.WorkerConfig.<init>(WorkerConfig.java:441) at org.apache.kafka.connect.runtime.distributed.DistributedConfig.<init>(DistributedConfig.java:591) at org.apache.kafka.connect.runtime.distributed.DistributedConfig.<init>(DistributedConfig.java:585) at org.apache.kafka.connect.cli.ConnectDistributed.createConfig(ConnectDistributed.java:108) at org.apache.kafka.connect.cli.ConnectDistributed.createConfig(ConnectDistributed.java:55) at org.apache.kafka.connect.cli.AbstractConnectCli.startConnect(AbstractConnectCli.java:123) at org.apache.kafka.connect.cli.AbstractConnectCli.run(AbstractConnectCli.java:94) at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:113)
checking the properties file:
`
$ k exec -it my-connect-cluster-connect-0 -- cat /tmp/strimzi-connect.properties
bootstrap.servers=
rest.advertised.host.name=my-connect-cluster-connect-0.my-connect-cluster-connect.cgf.svc
rest.advertised.port=8083
plugin.path=/opt/kafka/plugins
security.protocol=PLAINTEXT
producer.security.protocol=PLAINTEXT
consumer.security.protocol=PLAINTEXT
admin.security.protocol=PLAINTEXT
consumer.client.rack=
`
Image built using:
FROM dependencies.openet.com:5000/strimzi/kafka:0.45.0-kafka-3.8.1
Steps to reproduce
Expected behavior
Older kafka connect image should work with newer strimzi.
Strimzi version
0.46.1
Kubernetes version
1.32
Installation method
yaml
Infrastructure
Amazon AWS
Configuration files and logs
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
name: my-connect-cluster
spec:
version: 3.9.0
replicas: 1
image: artifactory.XXX.com:5000/XXX/my-connect-package:2.20.3
bootstrapServers: odf-cluster-kafka-bootstrap:9092
config:
group.id: connect-cluster
offset.storage.topic: connect-cluster-offsets
config.storage.topic: connect-cluster-configs
status.storage.topic: connect-cluster-status
# -1 means it will use the default replication factor configured in the broker
config.storage.replication.factor: -1
offset.storage.replication.factor: -1
status.storage.replication.factor: -1
key.converter: org.apache.kafka.connect.json.JsonConverter
value.converter: org.apache.kafka.connect.json.JsonConverter
Additional context
No response
Beta Was this translation helpful? Give feedback.
All reactions