我正在使用测试容器 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
在当前目录中可用,但事实可能并非如此(尝试运行cwd
或ls -la
并检查输出)。
但是如果你在 kafka-configs.sh
之前删除./
,它应该使用 PATH 变量中的命令,该命令应该在 Kafka 映像中配置。