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