如何在测试容器 kafka 镜像中执行 kafka-configs 命令



我正在使用测试容器 kafka 图像,它是流合的 cp-kafka,我需要使用命令修改 kafka 配置:

./kafka-configs.sh --alter --entity-name <TOPIC_NAME> --entity-type topics --add-config message.timestamp.type=LogAppendTime --zookeeper <HOST>:<PORT>

我有一个问题,使用 KafkaContainer::execInContainer 来执行此命令,它不会产生这样的文件或目录。

我已经查看了 GitHub 映像和 ubuntu 上的融合安装,它应该位于它的位置,并尝试了各种选项但没有成功。

如何正确执行此操作?

./kafka-configs.sh假设kafka-configs.sh在当前目录中可用,但事实可能并非如此(尝试运行cwdls -la并检查输出)。

但是如果你在 kafka-configs.sh 之前删除./,它应该使用 PATH 变量中的命令,该命令应该在 Kafka 映像中配置。

最新更新