Dear Manna,
What's the status of your SSL? Have you verified that the setup is working? Yes, I used " openssl s_client -debug -connect n1.test.com:9092 -tls1 Output: CONNECTED(00000003) write to 0x853e70 [0x89fd43] (155 bytes => 155 (0x9B)) 0000 - 16 03 01 00 96 01 00 00-92 03 01 59 8b 6d 0d b1 ...........Y.m.. ... Server certificate -----BEGIN CERTIFICATE----- CwwCSEsxGT............ -----END CERTIFICATE----- --- SSL handshake has read 2470 bytes and written 161 bytes --- New, TLSv1/SSLv3, Cipher is ECDHE-RSA-AES256-SHA PSK identity hint: None Start Time: 1502309645 Timeout : 7200 (sec) Verify return code: 19 (self signed certificate in certificate chain) --- Regards On Wed, Aug 9, 2017 at 10:29 PM, M. Manna <manme...@gmail.com> wrote: > Hi, > > What's the status of your SSL? Have you verified that the setup is working? > > You can enable rough logins using log4j.properties file supplier with kafka > and set the root logging level to DEBUG. This prints out more info to trace > things. Also, you can enable security logging by adding > -Djavax.security.debug=all > > Please share your producer/broker configs with us. > > Kindest Regards, > M. Manna > > On 9 August 2017 at 14:38, Ascot Moss <ascot.m...@gmail.com> wrote: > > > Hi, > > > > > > I have setup Kafka 0.10.2.1 with SSL. > > > > > > Check Status: > > > > openssl s_client -debug -connect n1:9093 -tls1 > > > > New, TLSv1/SSLv3, Cipher is ECDHE-RSA-AES256-SHA > > > > ... SSL-Session: > > > > Protocol : TLSv1 > > > > PSK identity hint: None > > > > Start Time: 1502285690 > > > > Timeout : 7200 (sec) > > > > Verify return code: 19 (self signed certificate in certificate chain) > > > > > > Create Topic: > > > > kafka-topics.sh --create --zookeeper n1:2181,n2:2181,n3:2181 > > --replication-factor 3 --partitions 3 --topic test02 > > > > ERROR [ReplicaFetcherThread-2-111], Error for partition [test02,2] to > > broker 1:org.apache.kafka.common.errors.UnknownTopicOrPartitionExcepti > on: > > This server does not host this topic-partition. > > (kafka.server.ReplicaFetcherThread) > > > > However, if I run describe topic, I can see it is created > > > > > > > > Describe Topic: > > > > kafka-topics.sh --zookeeper n1:2181,n2:2181,n3:2181 --describe --topic > > test02 > > > > Topic:test02 PartitionCount:3 ReplicationFactor:3 Configs: > > > > Topic: test02 Partition: 0 Leader: 12 Replicas: 12,13,11 Isr: 12,13,11 > > > > Topic: test02 Partition: 1 Leader: 13 Replicas: 13,11,12 Isr: 13,11,12 > > > > Topic: test02 Partition: 2 Leader: 11 Replicas: 11,12,13 Isr: 11,12,13 > > > > > > Consumer: > > > > kafka-console-consumer.sh --bootstrap-server n1:9093 --consumer.config > > /home/kafka/config/consumer.n1.properties --topic test02 > --from-beginning > > > > > > > > Producer: > > > > kafka-console-producer.sh --broker-list n1:9093 --producer.config > > /homey/kafka/config/producer.n1.properties --sync --topic test02 > > > > ERROR Error when sending message to topic test02 with key: null, value: 0 > > bytes with error: > > (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) > > > > org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) > for > > test02-1: 1506 ms has passed since batch creation plus linger time > > > > > > How to resolve it? > > > > Regards > > >