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
