У нас есть кластер Кафки в ec2.У нас есть ec2 ip как слушатели и advertised.listeners в server.properties.(у нас пока нет разрешения DNS).У нас есть MS в ec2 и k8s, которые могут подключиться к этому кластеру kafka и работать.
Теперь я пытаюсь настроить istio в k8s.Я создал запись DNS в route53, которая разрешает все ip кафки и добавляет ServiceEntry в istio.который должен открыть порт от посланника до кафки.
Проблема в Я могу сделать список тем kafka из istio, но не могу производить или потреблять. .DNS становится разрешенным, и порт kafka открыт с istio
Я подозреваю, что нам нужно изменить adsised.listeners на DNS, или я поставил ip всего кластера.Я не нашел решения от istio до kafka.Также не добавлена запись службы zookeeper. Должен ли я добавить, что я подключаюсь только к kafka, используя sarama lib?
Любая помощь приветствуется.
kakfa: 1.0.1, istio - 1.1.7
Я добавил ошибку производителя.
[2019-06-21 12:41:13,494] WARN [Producer clientId=console-producer] Got error produce response with correlation id 26 on topic-partition test-0, retrying (2 attempts left). Error: UNKNOWN_TOPIC_OR_PARTITION (org.apache.kafka.clients.producer.internals.Sender)
[2019-06-21 12:41:13,495] WARN [Producer clientId=console-producer] Received unknown topic or partition error in produce request on partition test-0. The topic-partition may not exist or the user may not have Describe access to it (org.apache.kafka.clients.producer.internals.Sender)
[2019-06-21 12:41:13,597] WARN [Producer clientId=console-producer] Got error produce response with correlation id 28 on topic-partition test-0, retrying (1 attempts left). Error: UNKNOWN_TOPIC_OR_PARTITION (org.apache.kafka.clients.producer.internals.Sender)
[2019-06-21 12:41:13,597] WARN [Producer clientId=console-producer] Received unknown topic or partition error in produce request on partition test-0. The topic-partition may not exist or the user may not have Describe access to it (org.apache.kafka.clients.producer.internals.Sender)
[2019-06-21 12:41:13,704] WARN [Producer clientId=console-producer] Got error produce response with correlation id 30 on topic-partition test-0, retrying (0 attempts left). Error: UNKNOWN_TOPIC_OR_PARTITION (org.apache.kafka.clients.producer.internals.Sender)
[2019-06-21 12:41:13,704] WARN [Producer clientId=console-producer] Received unknown topic or partition error in produce request on partition test-0. The topic-partition may not exist or the user may not have Describe access to it (org.apache.kafka.clients.producer.internals.Sender)
[2019-06-21 12:41:13,808] ERROR Error when sending message to topic test with key: null, value: 0 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2019-06-21 12:41:13,809] WARN [Producer clientId=console-producer] Received unknown topic or partition error in produce request on partition test-0. The topic-partition may not exist or the user may not have Describe access to it (org.apache.kafka.clients.producer.internals.Sender)