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.UnknownTopicOrPartitionException:
> 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
>

Reply via email to