#ssl #apache-kafka #kafka-consumer-api
Вопрос:
Я использую приведенную ниже команду для удаления группы потребителей Kafka с включенным SSL. Это работает нормально, но проблема в том, что я не хочу сохранять пароль в файле client-ssl.properties, вместо этого я должен иметь возможность динамически передавать пароль этой команде, например, «—переопределить опцию ssl.keystore.password 12345«. Я попытался использовать опцию —переопределить, но она не работает.
Пожалуйста, сообщите нам, как переопределить значения, присутствующие в файле client-ssl.properties, или есть ли какой-либо способ, которым я могу удалить группу потребителей без сохранения пароля в файле.
Команда:
kafkabinkafka-consumer-groups.sh --bootstrap-server localhost:9093 --command-config kafkaconfigclient-ssl.properties --delete --group ABCD
клиент-файл ssl.properties:
security.protocol=SSL
ssl.truststore.location=/server.truststore.jks
ssl.truststore.password=12345
ssl.keystore.location=/server.keystore.jks
ssl.keystore.password=12345
Ответ №1:
Если проблема заключается в необходимости ввода пароля в виде открытого текста на диске, то единственным обходным путем было бы написать собственную утилиту, которая вызывает тот же метод, что и сценарий оболочки, и динамически получает пароль откуда-то еще
Обратите внимание, что группы потребителей автоматически удаляются со временем, если они неактивны
Комментарии:
1. что касается автоматического удаления групп потребителей : Есть ли свойство конфигурации, в котором мы можем установить время истечения срока действия ? Поскольку я создал группу потребителей, и она была неактивна в течение 4 дней, теперь ее состояние ПУСТО с членами = 0, что означает, что она неактивна, но когда я запрашиваю список потребителей, я все еще нахожусь в списке с именем этой группы. Итак, пожалуйста, дайте мне знать, действительно ли группы потребителей удаляются ?
2. Это определяется настройками хранения смещений в конфигурации брокера