Kafka Connect не может читать темы Kafka по SSL
К сожалению, re.escape() не подходит для заменяющей строки:
>>> re.sub('a', re.escape('_'), 'aa')
'\\_\\_'
Решение состоит в том, чтобы поместить замену в лямбда:
>>> re.sub('a', lambda _: '_', 'aa')
'__'
, потому что возвращаемое значение лямбда обрабатывается re.sub() как литеральная строка.
0
задан Joseph Roffey 18 January 2019 в 16:45
поделиться
1 ответ
Я думаю, вам нужно добавить конфигурацию SSL как для потребителя, так и для производителя. Проверьте здесь Kafka Connect Encrypt с помощью SSL Как-то так
security.protocol=SSL
ssl.truststore.location=~/kafka.truststore.jks
ssl.truststore.password=<password>
ssl.keystore.location=~/kafka.client.keystore.jks
ssl.keystore.password=<password>
ssl.key.password=<password>
producer.security.protocol=SSL
producer.ssl.truststore.location=~/kafka.truststore.jks
producer.ssl.truststore.password=<password>
producer.ssl.keystore.location=~/kafka.client.keystore.jks
producer.ssl.keystore.password=<password>
producer.ssl.key.password=<password>
0
ответ дан suraj_fale 18 January 2019 в 16:45
поделиться
Другие вопросы по тегам: