我得到了很多以下动物园管理员警告日志:
2019-02-25 08:50:17599]信息客户端尝试在/172.17.22.182:42932(org.apache.zookeeper.server.zookeeperserver)建立新会话
[2019-02-25 08:50:17602]信息已建立会话0x100000519f70036,为客户端/172.17.22.182:42932协商超时4000(org.apache.zookeeper.server.zookeeperserver)
[2019-02-25 08:50:20478]warn无法从客户端sessionid 0x100000519f70036读取其他数据,可能客户端已关闭套接字(org.apache.zookeeper.server.nioservercnxn)
[2019-02-25 08:50:20479]客户端的信息已关闭套接字连接/172.17.22.182:42932,会话ID为0x100000519f70036(org.apache.zookeeper.server.nioservercnxn)
[2019-02-25 08:50:24983]信息接受来自/172.17.21.38:45994的套接字连接(org.apache.zookeeper.server.nioservercnxnfactory)
[2019-02-25 08:50:24984]如果服务器处于R-O模式(org.apache.zookeeper.server.zookeeperserver),则将删除旧客户端/172.17.21.38:45994发出的警告连接请求。
[2019-02-25 08:50:24984]信息客户端尝试在/172.17.21.38:45994建立新会话(org.apache.zookeeper.server.zookeeperserver)
[2019-02-25 08:50:24987]信息已建立会话0x100000519f70037,为客户端/172.17.21.38:45994协商超时4000(org.apache.zookeeper.server.zookeeperserver)
[2019-02-25 08:50:28871]warn无法从客户端sessionid 0x100000519f70037读取其他数据,客户端可能已关闭套接字(org.apache.zookeeper.server.nioservercnxn)
[2019-02-25 08:50:28872]客户端的信息已关闭套接字连接/172.17.21.38:45994,会话ID为0x100000519f70037(org.apache.zookeeper.server.nioservercnxn)
[2019-02-25 08:50:35612]信息接受来自/172.17.22.182:42942的套接字连接(org.apache.zookeeper.server.nioservercnxnfactory)
[2019-02-25 08:50:35612]如果服务器处于R-O模式(org.apache.zookeeper.server.zookeeperserver),则将删除旧客户端/172.17.22.182:42942发出的警告连接请求。
[2019-02-25 08:50:35612]信息客户端尝试在/172.17.22.182:42942建立新会话(org.apache.zookeeper.server.zookeeperserver)
[2019-02-25 08:50:35615]为客户端/172.17.22.182:42942(org.apache.zookeeper.server.zookeeperserver)建立信息会话0x100000519f70038,协商超时4000
[2019-02-25 08:50:38492]warn无法从客户端sessionid 0x100000519f70038读取其他数据,可能客户端已关闭套接字(org.apache.zookeeper.server.nioservercnxn)
[2019-02-25 08:50:38493]客户端的信息已关闭套接字连接
/172.17.22.182:42942,会话ID为0x100000519f70038(org.apache.zookeeper.server.nioservercnxn)
我的集群结构是:3个ZooKeeper节点和3个Kafka节点,每个节点在基于Docker的不同EC2机器上(共6个),我从
confluent
注意:我的kafka节点和zookeeper节点与sasl_ssl通信
这是我的动物园管理员Docker写的:
zookeeper:
container_name: zookeeper
image: confluentinc/cp-zookeeper:5.1.2
ports:
- "2181:2181"
- "30001:30001"
volumes:
- "/mnt/zookeeper/data:/var/lib/zookeeper/data"
- "/mnt/zookeeper/logs:/var/lib/zookeeper/log"
- "/etc/me/secrets/zookeeper_secrets:/etc/kafka/secrets/"
environment:
ZOOKEEPER_SERVER_ID: <%= zookeeperServerId %>
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
ZOOKEEPER_INIT_LIMIT: 5
ZOOKEEPER_SYNC_LIMIT: 2
ZOOKEEPER_SERVERS: <%= zookeeperDockerServerList %>
KAFKA_OPTS: "-Djava.security.auth.login.config=/etc/kafka/secrets/zookeeper_jaas.conf -Dzookeeper.authProvider.1=org.apache.zookeeper.server.auth.SASLAuthenticationProvider"
network_mode: host
