We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Hi
I have created this ClusterLink, but kafka pods reports this errors en destination cluster:
[ERROR] 2025-02-16 16:54:05,790 [kafka-admin-client-thread | cluster-link-client-admin-clusterlink-tfn-global-destination-2] org.apache.kafka.clients.NetworkClient initiateReverseConnect - [AdminClient clientId=cluster-link-client-admin-clusterlink-tfn-global-destination-2] Error initiating reverse connection to node localhost:0 (id: -1 rack: null)
kind: ClusterLink apiVersion: platform.confluent.io/v1beta1 metadata: name: clusterlink-tfn-global namespace: kafkades spec: configs: connections.max.idle.ms: "350000" cluster.link.retry.timeout.ms: "900000" sourceInitiatedLink: linkMode: Destination destinationKafkaCluster: kafkaRestClassRef: name: kafkarestclass namespace: kafkades sourceKafkaCluster: authentication: type: mtls tls: enabled: true secretRef: kafka-tls-secret-kafkaadmin bootstrapEndpoint: kafkapro.sistemasti.int:443 clusterID: pm9MXZPnTqqhRc7PjV7U8w kafkaRestClassRef: name: kafkarestclass namespace: kafkapro mirrorTopics: - name: test mirrorTopicOptions: autoCreateTopics: enabled: true
The text was updated successfully, but these errors were encountered:
No branches or pull requests
Hi
I have created this ClusterLink, but kafka pods reports this errors en destination cluster:
[ERROR] 2025-02-16 16:54:05,790 [kafka-admin-client-thread | cluster-link-client-admin-clusterlink-tfn-global-destination-2] org.apache.kafka.clients.NetworkClient initiateReverseConnect - [AdminClient clientId=cluster-link-client-admin-clusterlink-tfn-global-destination-2] Error initiating reverse connection to node localhost:0 (id: -1 rack: null)
kind: ClusterLink
apiVersion: platform.confluent.io/v1beta1
metadata:
name: clusterlink-tfn-global
namespace: kafkades
spec:
configs:
connections.max.idle.ms: "350000"
cluster.link.retry.timeout.ms: "900000"
sourceInitiatedLink:
linkMode: Destination
destinationKafkaCluster:
kafkaRestClassRef:
name: kafkarestclass
namespace: kafkades
sourceKafkaCluster:
authentication:
type: mtls
tls:
enabled: true
secretRef: kafka-tls-secret-kafkaadmin
bootstrapEndpoint: kafkapro.sistemasti.int:443
clusterID: pm9MXZPnTqqhRc7PjV7U8w
kafkaRestClassRef:
name: kafkarestclass
namespace: kafkapro
mirrorTopics:
- name: test
mirrorTopicOptions:
autoCreateTopics:
enabled: true
The text was updated successfully, but these errors were encountered: