Сконфигурируйте реестр схемы, чтобы использовать только сопоставление протоколов "CLIENT_SECURE" для подключения к списку брокеров, возвращенному zookeeper - PullRequest
0 голосов
/ 10 февраля 2020

Я запускаю кластер Kafka / Zk в AWS MSK и подключаю к нему реестр схемы.

Если я указываю список посредников в kafkastore.bootstrap.servers, он подключается нормально (по протоколу SSL). Однако, если я удаляю bootstrap config сервера и переключаюсь на запрос Zookeeper для обнаружения брокера, используя kafkastore.connection.url, я не могу подключиться к кластеру. Это из-за того, что Zookeeper возвращает из запросов брокера и как SR его использует:

$ ./bin/zkCli.sh -server z-1.cluster.address:2181
> ls /brokers/ids
[1, 2]
> get /brokers/ids/1
{
  "listener_security_protocol_map": {
    "CLIENT_SECURE": "SSL",
    "REPLICATION": "PLAINTEXT",
    "REPLICATION_SECURE": "SSL"
  },
  "endpoints": [
    "CLIENT_SECURE://b-1.cluster.address:9094",
    "REPLICATION://b-1-internal.cluster.address:9093",
    "REPLICATION_SECURE://b-1-internal.cluster.address:9095"
  ],
  ....
}

Я предполагаю, что, указав SSL протокол, он разрешает карту обратно и затем подключается к CLIENT_SECURE и REPLICATION_SECURE. конечные точки. Однако все -internal.cluster.address конечные точки недоступны.

Можно настроить SR на использование только CLIENT_SECURE конечных точек и не пытаться подключиться к REPLICATION_SECURE единицам?

Это связано с https://github.com/confluentinc/schema-registry/issues/1126

...