Я не могу использовать порт 9093 для соединения SSL, несмотря на внесение изменений в файл server.properties
listeners=PLAINTEXT://0.0.0.0:9092,SSL://0.0.0.0:9093
advertised.listeners=PLAINTEXT:XXXXX:9092,SSL:XXX:9093
zookeeper.connect=xxx:2181
ssl.truststore.location=/home/ubuntu/kafka.server.truststore.jks
ssl.truststore.password=XXX
ssl.keystore.location=/home/ubuntu/kafka.server.keystore.jks
ssl.keystore.password=XXX
ssl.key.password=XXX
ssl.endpoint.identification.algorithm=
Когда я перезагружаю Брокер и запускаю следующую команду
sudo grep "EndPoint" /home/ubuntu/kafka/logs/server.log
Я получаю
[2020-01-12 18:00:58,954] INFO [SocketServer brokerId=0] Created data-plane acceptor and processors for endpoint : EndPoint(null,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer)
[2020-01-12 18:00:59,057] INFO Registered broker 0 at path /brokers/ids/0 with addresses: ArrayBuffer(EndPoint(ip-172-31-41-124.ec2.internal,9092,ListenerName(PLAINTEXT),PLAINTEXT)), czxid (broker epoch): 111 (kafka.zk.KafkaZkClient)
[2020-01-12 18:05:02,804] INFO [SocketServer brokerId=0] Created data-plane acceptor and processors for endpoint : EndPoint(null,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer)
[2020-01-12 18:05:02,909] INFO Registered broker 0 at path /brokers/ids/0 with addresses: ArrayBuffer(EndPoint(ip-172-31-41-124.ec2.internal,9092,ListenerName(PLAINTEXT),PLAINTEXT)), czxid (broker epoch): 130 (kafka.zk.KafkaZkClient)
[2020-01-12 18:07:13,649] INFO [SocketServer brokerId=0] Created data-plane acceptor and processors for endpoint : EndPoint(null,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer)
[2020-01-12 18:07:13,753] INFO Registered broker 0 at path /brokers/ids/0 with addresses: ArrayBuffer(EndPoint(ip-172-31-41-124.ec2.internal,9092,ListenerName(PLAINTEXT),PLAINTEXT)), czxid (broker epoch): 149 (kafka.zk.KafkaZkClient)
[2020-01-12 18:09:57,479] INFO [SocketServer brokerId=0] Created data-plane acceptor and processors for endpoint : EndPoint(null,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer)
[2020-01-12 18:09:57,588] INFO Registered broker 0 at path /brokers/ids/0 with addresses: ArrayBuffer(EndPoint(ip-172-31-41-124.ec2.internal,9092,ListenerName(PLAINTEXT),PLAINTEXT)), czxid (broker epoch): 168 (kafka.zk.KafkaZkClient)
[2020-01-12 18:10:07,310] INFO [SocketServer brokerId=0] Created data-plane acceptor and processors for endpoint : EndPoint(null,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer)
[2020-01-12 18:10:07,413] INFO Registered broker 0 at path /brokers/ids/0 with addresses: ArrayBuffer(EndPoint(ip-172-31-41-124.ec2.internal,9092,ListenerName(PLAINTEXT),PLAINTEXT)), czxid (broker epoch): 201 (kafka.zk.KafkaZkClient)
[2020-01-12 18:10:34,055] INFO [SocketServer brokerId=0] Created data-plane acceptor and processors for endpoint : EndPoint(null,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer)
[2020-01-12 18:10:34,163] INFO Registered broker 0 at path /brokers/ids/0 with addresses: ArrayBuffer(EndPoint(ip-172-31-41-124.ec2.internal,9092,ListenerName(PLAINTEXT),PLAINTEXT)), czxid (broker epoch): 221 (kafka.zk.KafkaZkClient)
[2020-01-12 18:11:57,920] INFO [SocketServer brokerId=0] Created data-plane acceptor and processors for endpoint : EndPoint(null,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer)
[2020-01-12 18:11:58,029] INFO Registered broker 0 at path /brokers/ids/0 with addresses: ArrayBuffer(EndPoint(ip-172-31-41-124.ec2.internal,9092,ListenerName(PLAINTEXT),PLAINTEXT)), czxid (broker epoch): 240 (kafka.zk.KafkaZkClient)
И когда я бегу
sudo grep "Exception" /home/ubuntu/kafka/logs/server.log
[2020-01-12 18:00:58,116] INFO Got user-level KeeperException when processing sessionid:0x1000022bd050004 type:create cxid:0x1 zxid:0x62 txntype:-1 reqpath:n/a Error Path:/consumers Error:KeeperErrorCode = NodeExists for /consumers (org.apache.zookeeper.server.PrepRequestProcessor)
[2020-01-12 18:00:58,125] INFO Got user-level KeeperException when processing sessionid:0x1000022bd050004 type:create cxid:0x2 zxid:0x63 txntype:-1 reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists for /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor)
[2020-01-12 18:00:58,130] INFO Got user-level KeeperException when processing sessionid:0x1000022bd050004 type:create cxid:0x5 zxid:0x66 txntype:-1 reqpath:n/a Error Path:/admin/delete_topics Error:KeeperErrorCode = NodeExists for /admin/delete_topics (org.apache.zookeeper.server.PrepRequestProcessor)
[2020-01-12 18:00:58,132] INFO Got user-level KeeperException when processing sessionid:0x1000022bd050004 type:create cxid:0x6 zxid:0x67 txntype:-1 reqpath:n/a Error Path:/brokers/seqid Error:KeeperErrorCode = NodeExists for /brokers/seqid (org.apache.zookeeper.server.PrepRequestProcessor)
[2020-01-12 18:00:58,134] INFO Got user-level KeeperException when processing sessionid:0x1000022bd050004 type:create cxid:0x7 zxid:0x68 txntype:-1 reqpath:n/a Error Path:/isr_change_notification Error:KeeperErrorCode = NodeExists for /isr_change_notification (org.apache.zookeeper.server.PrepRequestProcessor)
[2020-01-12 18:00:58,136] INFO Got user-level KeeperException when processing sessionid:0x1000022bd050004 type:create cxid:0x8 zxid:0x69 txntype:-1 reqpath:n/a Error Path:/latest_producer_id_block Error:KeeperErrorCode = NodeExists for /latest_producer_id_block (org.apache.zookeeper.server.PrepRequestProcessor)
[2020-01-12 18:00:58,137] INFO Got user-level KeeperException when processing sessionid:0x1000022bd050004 type:create cxid:0x9 zxid:0x6a txntype:-1 reqpath:n/a Error Path:/log_dir_event_notification Error:KeeperErrorCode = NodeExists for /log_dir_event_notification (org.apache.zookeeper.server.PrepRequestProcessor)
[2020-01-12 18:00:58,139] INFO Got user-level KeeperException when processing sessionid:0x1000022bd050004 type:create cxid:0xa zxid:0x6b txntype:-1 reqpath:n/a Error Path:/config/topics Error:KeeperErrorCode = NodeExists for /config/topics (org.apache.zookeeper.server.PrepRequestProcessor)
[2020-01-12 18:00:58,141] INFO Got user-level KeeperException when processing sessionid:0x1000022bd050004 type:create cxid:0xb zxid:0x6c txntype:-1 reqpath:n/a Error Path:/config/clients Error:KeeperErrorCode = NodeExists for /config/clients (org.apache.zookeeper.server.PrepRequestProcessor)
[2020-01-12 18:00:58,142] INFO Got user-level KeeperException when processing sessionid:0x1000022bd050004 type:create cxid:0xc zxid:0x6d txntype:-1 reqpath:n/a Error Path:/config/users Error:KeeperErrorCode = NodeExists for /config/users (org.apache.zookeeper.server.PrepRequestProcessor)
[2020-01-12 18:00:58,144] INFO Got user-level KeeperException when processing sessionid:0x1000022bd050004 type:create cxid:0xd zxid:0x6e txntype:-1 reqpath:n/a Error Path:/config/brokers Error:KeeperErrorCode = NodeExists for /config/brokers (org.apache.zookeeper.server.PrepRequestProcessor)