Kafka Zookeeper нестандартные порты - PullRequest
Новая
       52

Kafka Zookeeper нестандартные порты

1 голос
/ 07 ноября 2019

Я вижу некоторые недокументированные порты, используемые zookeeper в нашем развертывании kafka (kafka_2.12-2.3.0). Насколько я понимаю, Kafka / Zookeeper использует 9092, 9093, 2181, 2888, 3888. Мы видим попытки подключения в диапазоне портов 50000. Нам необходимо максимально точно настроить брандмауэры. Я пропустил что-то настроенное или их другие нестандартные порты используют Kafka / Zookeeper?

Вывод из zookeeper 

[2019-11-07 11:33:55,240] INFO Accepted socket connection from /192.168.0.52:52030 (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2019-11-07 11:33:55,246] INFO Client attempting to establish new session at /192.168.0.52:52030 (org.apache.zookeeper.server.ZooKeeperServer)
[2019-11-07 11:33:55,250] INFO Established session 0x3004c34f9640003 with negotiated timeout 30000 for client /192.168.0.52:52030 (org.apache.zookeeper.server.ZooKeeperServer)
[2019-11-07 11:33:55,765] INFO Closed socket connection for client /192.168.0.52:52030 which had sessionid 0x3004c34f9640003 (org.apache.zookeeper.server.NIOServerCnxn)
[2019-11-07 11:34:16,499] INFO Accepted socket connection from /192.168.0.52:52038 (org.apache.zookeeper.server.NIOServerCnxnFactory)

zookeeper.properites 

# the port at which the clients will connect
clientPort=2181
# disable the per-ip limit on the number of connections since this is a non-production config
maxClientCnxns=0
server.1=192.168.0.52:2888:3888
server.2=192.168.0.53:2888:3888
server.3=192.168.0.54:2888:3888

сервер. свойства 

############################# Socket Server Settings #############################

# The address the socket server listens on. It will get the value returned from
# java.net.InetAddress.getCanonicalHostName() if not configured.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
listeners=PLAINTEXT://192.168.0.52:9092

# Hostname and port the broker will advertise to producers and consumers. If not set,
# it uses the value for "listeners" if configured.  Otherwise, it will use the value
# returned from java.net.InetAddress.getCanonicalHostName().
advertised.listeners=PLAINTEXT://192.168.0.52:9092

1 Ответ

0 голосов
/ 07 ноября 2019

В журналах вы видите сокет (хост и порт) удаленного клиента, подключающегося к Zookeeper.

Вы настроили Zookeeper на прослушивание через порт 2888, но клиент, подключающийся к Zookeeper, может использовать любойего (клиентских) портов.

Например, в: 

Accepted socket connection from /192.168.0.52:52038

Это означает, что что-то (возможно, Kafka или Zookeeper) из 192.168.0.52:52038 подключено к Zookeeper. 

Client                      Zookeeper
192.168.0.52:52038   ---->  192.168.0.52:2888
...