Resultados de la búsqueda a petición "confluent"

1 la respuesta

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 ...

2 la respuesta

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 ...

1 la respuesta

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 ...

0 la respuesta

¿Es posible usar la combinación izquierda múltiple en una consulta KSQL confluente? intentó unir stream con más de 1 tablas, si no, ¿cuál es la solución?

Stream: describe ammas; Field | Type ------------------------------------- ROWTIME | BIGINT (system) ROWKEY | VARCHAR(STRING) (system) ID | INTEGER -------------------------------------Para las estadísticas de tiempo de ejecución y los detalles ...

2 la respuesta

KafkaAvroDeserializer no devuelve SpecificRecord pero devuelve GenericRecord

MiKafkaProducer es capaz de usarKafkaAvroSerializer para serializar objetos a mi tema. Sin embargo,KafkaConsumer.poll() devoluciones deserializadasGenericRecord en lugar de mi clase serializada. MyKafkaProducer KafkaProducer<CharSequence, ...