时间戳

首页 > 解决方案 > 如何在 testcontainers kafka 映像中执行 kafka-configs 命令

apache-kafka - 如何在 testcontainers kafka 映像中执行 kafka-configs 命令

问题描述

我正在使用融合 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 安装，它应该位于它应该位于的位置，并尝试了各种选项但没有成功。

如何正确地做到这一点？

标签： apache-kafkaconfluent-platformtestcontainers

解决方案

./kafka-configs.sh假设kafka-configs.sh在当前目录中可用，但情况可能并非如此（尝试运行cwd或ls -la检查输出）。

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

推荐阅读