alert-traffic-45034
10/06/2022, 8:07 AMhelm install the datahub applications with a self-managed aws msk instead of the shipped kafka image. But I come across an error while running the kafka setup job. May I have your help in it ? thanks in advance
error log:
Error while executing config command with args '--command-config /tmp/connection.properties --bootstrap-server <my-msk-broker-endpoints> --entity-type topics --entity-name _schemas --alter --add-config cleanup.policy=compact'
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support INCREMENTAL_ALTER_CONFIGS
at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:104)
at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:272)
at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:335)
at kafka.admin.ConfigCommand$.processCommand(ConfigCommand.scala:302)
at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:97)
at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
spec:
Kafka version: 2.2.1
job setting:
kafkaSetupJob:
enabled: true
image:
repository: linkedin/datahub-kafka-setup
tag: "v0.8.44"
podSecurityContext:
fsGroup: 1000
securityContext:
runAsUser: 1000
podAnnotations: {}alert-traffic-45034
10/06/2022, 10:29 AMbrainy-beach-58125
06/13/2023, 12:15 PM