我正在使用融合 cp-kafka 的testcontainers kafka 映像,我需要使用命令修改 kafka 配置:
./kafka-configs.sh --alter --entity-name <TOPIC_NAME> --entity-type topics --add-config message.timestamp.type=LogAppendTime --zookeeper <HOST>:<PORT>
我在执行此命令时遇到问题,使用KafkaContainer::execInContainer
它不会产生这样的文件或目录。
我在 ubuntu 上查看了 github 图像和 confluent 安装,它应该位于它应该位于的位置,并尝试了各种选项但没有成功。
如何正确地做到这一点?