Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Quiero entender cómo pulsar usa debezium io connect para CDC. Al crear la fuente usando pulsar-admin source create, ¿cómo puedo pasar la URL de broker y los parámetros de autenticación o cliente? Similar a lo que hacemos al usar localrun. El comando que ejecuto: bin/pulsar-admin source localrun –sourceConfigFile debezium-mysql-source-config.yaml –client-auth-plugin . . . Read more
Tengo un conector de debezium que funciona bien, pero solo por un tiempo limitado. Estos errores ocurren en el archivo de registro: Caused by: java.sql.SQLException: ORA-00308: no se puede abrir el archivo de registro archivado ‘+RECO/XXXXXXXX/ARCHIVELOG/2022_01_04/thread_1_seq_53874.3204.1093111215’ ORA-17503: ksfdopn:2 No se pudo abrir el archivo +RECO/XXXXXXXX/ARCHIVELOG/2022_01_04/thread_1_seq_53874.3204.1093111215 ORA-15012: El archivo ASM ‘+RECO/XXXXXX/ARCHIVELOG/2022_01_04/thread_1_seq_53874.3204.1093111215’ . . . Read more
Como dice el título, tengo dos servidores separados y quiero que ambos conectores lea de la misma fuente y escriba en su respectivo tema. Un conector único funciona bien. Cuando creo otro en un servidor diferente, parecen estar funcionando pero no hay flujo de datos para ambos. Mi pregunta es, . . . Read more
Tenemos un clúster de MongoDB con tres réplicas. He habilitado TLS preferido y el tipo de autenticación como MongoDB-X509. Tenemos un clúster de Kafka Strimzi con tres brokers y un clúster de conexión con todos los complementos necesarios (por ejemplo, MongoDB proporcionado por Debezium) funcionando correctamente. A continuación se muestra . . . Read more
Estoy desplegando KafkaCluster, KafkaConnect en K8s utilizando Strimzi. Imagen del Clúster del Operador Strimzi: quay.io/strimzi/operator:0.26.1 Imagen de Kafka: quay.io/strimzi/kafka:0.26.1-kafka-3.0.0. Estoy tratando de configurar KafkaConnector que se conecta a una base de datos de Postgres. Estos son mis pasos: Construir un nuevo KafkaConnect a partir de esta imagen ‘quay.io/strimzi/kafka:0.26.1-kafka-3.0.0’. Esta nueva . . . Read more