Estoy usando Confluent 3.2 en un conjunto de contenedores Docker, uno de los cuales ejecuta un trabajador de conexión kafka.

Por razones que aún no me quedan claras, dos de mis cuatro conectores (para ser específicos, el conector receptor MongoDB de hpgraphsl) dejaron de funcionar. Pude identificar el problema principal: los conectores no tenían ninguna tarea asignada, como se podía ver llamando a GET /connectors/{my_connector}/status . Los otros dos conectores (del mismo tipo) no se vieron afectados y producían felizmente la salida.

Probé tres métodos diferentes para que mis conectores vuelvan a funcionar a través de la API REST:

• Pausar y reanudar los conectores
• Reinicio de los conectores
• Eliminar y crear el conector con el mismo nombre, usando la misma configuración

Ninguno de los métodos funcionó. Finalmente conseguí que mis conectores funcionaran de nuevo:

• Eliminar y crear el conector con un nombre diferente, diga my_connector_v2 en lugar de my_connector

¿Que esta pasando aqui? ¿Por qué no puedo reiniciar mi conector existente y hacer que inicie una tarea real? ¿Hay algún dato obsoleto en el trabajador de kafka-connect o en algún tema relacionado con kafka-connect en los corredores de Kafka que deba limpiarse?

Presenté un problema en el repositorio de github del conector específico, pero siento que esto podría ser un error general relacionado con los aspectos intrínsecos de kafka-connect. ¿Algunas ideas?