Resultados da pesquisa a pedido "confluent"
EDIÇÃO DE FORMATO DO KSQL AVRO para a Pesquisa Elástica do Kafka Connect: org.apache.kafka.connect.errors.DataException: de ****** ense
A seguinte exceção está sendo lançada para o Elastic Search Connector: [2018-05-07 11:40:38,975] ERROR WorkerSinkTask{id=elasticsearch-sink-0} Task threw an uncaught and unrecoverable ...
KafkaAvroDeserializer não retorna SpecificRecord, mas retorna GenericRecord
MinhasKafkaProducer é capaz de usarKafkaAvroSerializer serializar objetos para o meu tópico. Contudo,KafkaConsumer.poll() retorna desserializadoGenericRecord em vez da minha classe serializada. MyKafkaProducer KafkaProducer<CharSequence, ...
Como buscar o esquema do conector de origem Kafka com base no nome do conector
Estou usando o conector Confluent JDBC Kafka para publicar mensagens no tópico. O conector de origem enviará dados para o tópico junto com o esquema em cada pesquisa. Quero recuperar esse esquema. É possível? Quão? Alguém pode me sugerir inha ...
Reiniciar a tarefa de pia do Kafka Connect S3 perde a posição, reescreve completamente tudo
Após reiniciar uma tarefa de coletor do Kafka Connect S3, ele reiniciou a gravação desde o início do tópico e gravou cópias duplicadas dos registros mais antigos. Em outras palavras, o Kafka Connect pareceu perder seu lugar. Então, imagino que o ...
É possível usar várias associações à esquerda na consulta Confluent KSQL? tentou ingressar no stream com mais de 1 tabelas, se não, então qual é a solução?
Corrente : describe ammas; Field | Type ------------------------------------- ROWTIME | BIGINT (system) ROWKEY | VARCHAR(STRING) (system) ID | INTEGER -------------------------------------Para estatísticas de tempo de execução e detalhes da ...