2017-02-01 4 views
0

Lors du test de kafka connect en mode distribué, nous avons constaté qu'il fonctionne en mode veille plutôt qu'en mode actif actif.Est-ce que kafka connect supporte le mode actif-actif en mode distribué?

Si nous avons un cluster à deux membres, un seul fonctionne à la fois pour le connecteur de récepteur HDFS et l'autre en attente. Si le premier meurt ou est interrompu, alors le second en attente reprend l'opération.

Fonctionne-t-elle de sorte que les deux fonctionnent ensemble avec différents noms de puits pour HDFS sous un ID de groupe de cluster unique et si l'un tombe, l'opération de vidage n'est pas interrompue du tout? ?

Répondre

0

Il a été atteint après avoir augmenté la valeur de tasks.max dans la charge utile JSON dans l'API REST du connecteur à 4 (essentiellement supérieure à 1).