Как выполнить команду kafka-configs внутри testcontainers kafka image

Question

Я использую образ testcontainers 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, где он должен находиться, и попробовал различные варианты, но безуспешно.

Как правильно это сделать?

Answer 1

./kafka-configs.sh предполагает, что kafka-configs.sh доступно в текущем каталоге, что может быть не так (попробуйте запустить cwd или же ls -la вместо этого и проверьте вывод).

Но если вы удалите ./ до kafka-configs.sh, он должен использовать команду из переменной PATH, которая должна быть настроена внутри образа Kafka.