时间戳

首页 > 解决方案 > Confluent Platform：Confluent Platform 和 Apache Kafka 版本之间的版本对齐

apache-kafka - Confluent Platform：Confluent Platform 和 Apache Kafka 版本之间的版本对齐

问题描述

OS: ubuntu 18.x
Confluent Schema Registry:  community edition version 5.5.1
Kafka:  AWS MKS (Apache Kafka 2.2.1)

我正在围绕几个与删除引用过时模式 ID 的主题日志有关的问题。该具体问题以前曾报道过。在此，我就相关事宜进行阐述。

我决定删除我的主题的所有日志——称之为TOP。在几篇文章（包括来自 Confluent docs的一篇文章）之后，我尝试将我的主题的保留时间设置为 1 秒。例如：

$ ./kafka-topics --bootstrap-server "b-3.amazonaws.com:9092,b-2.amazonaws.com:9092,b-1.amazonaws.com:9092" --alter --config retention.ms=1000 --topic TOP
Option combination "[bootstrap-server],[config]" can't be used with option "[alter]"
...

正如此处的输出所示，该命令失败并建议使用不适当的命令行选项组合。然后我尝试了类似的kafka-configs命令：

$ ./kafka-configs --bootstrap-server "b-3.amazonaws.com:9092,b-2.amazonaws.com:9092,b-1.amazonaws.com:9092" --entity-type topics --entity-name TOP --alter --add-config retention.ms=1000
Error while executing config command with args '--bootstrap-server b-3.amazonaws.com:9092,b-2.amazonaws.com:9092,b-1.amazonaws.com:9092 --entity-type topics --entity-name call --alter --add-config retention.ms=1000'
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:327)
    at kafka.admin.ConfigCommand$.processCommand(ConfigCommand.scala:298)
    at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:91)
    at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
Caused by: org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support INCREMENTAL_ALTER_CONFIGS

因此，我怀疑我引用的 Confluent 文档与我通过 AWS MKS 使用的 Kafka 版本之间存在脱节。在这种情况下，设置主题特定配置属性的推荐做法是什么？

更一般地说，任何人都可以澄清 Apache Kafka 版本和 Confluent 平台之间的版本一致性吗？

标签： apache-kafkaconfluent-platformconfluent-schema-registry

解决方案

推荐阅读