Resultados da pesquisa a pedido "apache-kafka-connect"
Adicionando um conector ao Kafka Connect
Estou usando a imagem Confluent Kafka Docker, especificamente usando ...
É possível no Debezium configurar table_name => mapeamento de tópicos kafka?
Eu lihttp://debezium.io/docs/connectors/mysql/ [http://debezium.io/docs/connectors/mysql/]mas não consegui encontrar nenhuma informação sobre se o debezium pode ser configurado para que alterações de 2 (ou mais) tabelas possam ser gravadas no ...
Os trabalhos de conexão dos consumidores estão sendo excluídos ao reiniciar o cluster
Estou enfrentando o problema abaixo ao alterar algumas propriedades relacionadas ao kafka e reiniciar o cluster. In kafka Consumer, there were 5 consumer jobs are running .Se fizermos alguma alteração importante na propriedade e, ao reiniciar o ...
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 ...
O conector do coletor Kafka Connect JDBC não está funcionando
Estou tentando usar o conector de coletor Kafka Connect JDBC para inserir dados no Oracle, mas está apresentando um erro. Eu tentei com todas as configurações possíveis do esquema. Abaixo estão os exemplos. Por favor, sugira que, se faltar ...
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 ...
Kafka Connect ficando sem espaço no heap
Depois de iniciar o Kafka Connect (connect-standalone), minha tarefa falha imediatamente após iniciar com: java.lang.OutOfMemoryError: Java heap space at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57) ...