Resultados de la búsqueda a petición "apache-kafka-connect"
¿Es posible en Debezium configurar table_name => mapeo de temas kafka?
he leídohttp://debezium.io/docs/connectors/mysql/ [http://debezium.io/docs/connectors/mysql/]pero no pude encontrar ninguna información sobre si debezium se puede configurar para que los cambios de 2 (o más) tablas se puedan escribir en el mismo ...
Reiniciar Kafka Connect S3 Sink Task pierde posición, reescribe completamente todo
Después de reiniciar una tarea de sumidero de Kafka Connect S3, reinició la escritura desde el principio del tema y escribió copias duplicadas de registros anteriores. En otras palabras, Kafka Connect parecía perder su lugar. Por lo tanto, me ...
El conector del sumidero Kafka Connect JDBC no funciona
Estoy tratando de usar el conector de sumidero Kafka Connect JDBC para insertar datos en Oracle, pero arroja un error. He intentado con todas las configuraciones posibles del esquema. Debajo están los ejemplos. Sugiera si me falta algo a ...
Cómo obtener el esquema del conector de origen Kafka basado en el nombre del conector
Estoy usando el conector Confluent JDBC Kafka para publicar mensajes en el tema. El conector de origen enviará datos al tema junto con el esquema en cada encuesta. Quiero recuperar este esquema. ¿Es posible? ¿Cómo? ¿Alguien puede sugerirme Mi ...
Kafka Connect se queda sin espacio de almacenamiento dinámico
Después de iniciar Kafka Connect (connect-standalone), mi tarea falla inmediatamente después de comenzar con: java.lang.OutOfMemoryError: Java heap space at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57) ...
KSQL AVRO FORMAT ISSUE para Kafka Connect Elastic Search: org.apache.kafka.connect.errors.DataException: de ****** ense
Se está lanzando una excepción para Elastic Search Connector: [2018-05-07 11:40:38,975] ERROR WorkerSinkTask{id=elasticsearch-sink-0} Task threw an uncaught and unrecoverable ...
Agregar un conector a Kafka Connect
Estoy usando la imagen Confluent Kafka Docker, específicamente usando ...
Los trabajos de Connect consumer se eliminan al reiniciar el clúster
Estoy enfrentando el siguiente problema al cambiar algunas propiedades relacionadas con kafka y reiniciar el clúster. In kafka Consumer, there were 5 consumer jobs are running .Si realizamos algún cambio importante en la propiedad, y al ...