Resultados da pesquisa a pedido "apache-kafka"
É 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 ...
Filtragem de fluxos Kafka: lado do corretor ou consumidor?
Eu estou olhando para córregos kafka. Quero filtrar meu fluxo usando um filtro com seletividade muito baixa (um em poucos milhares). Eu estava olhando para este ...
Como o commit automático do consumidor kafka funciona?
estou lendoeste [https://www.safaribooksonline.com/library/view/kafka-the-definitive/9781491936153/ch04.html#callout_kafka_consumers__reading_data_from_kafka_CO2-1] : Confirmação automática A maneira mais fácil de cometer compensações é ...
A reatribuição kafka de __consumer_offsets está incorreta?
Estou confuso com o funcionamento do kafka-reassignment-paritions no tópico __consumer_offsets? Começo com 1 zk e 1 kafka broker, crio um tópico de teste com replicação = 1, partição = 1. consumir e produzir. funciona bem. Eu vejo o tópico ...
Como obter compensações Kafka para consultas estruturadas para gerenciamento manual e confiável de compensações?
O Spark 2.2 introduziu uma fonte de streaming estruturada do Kafka. Pelo que entendi, ele conta com o diretório de ponto de verificação do HDFS para armazenar compensações e garantir uma entrega de mensagem "exatamente uma vez". Mas docas ...
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 ...
Como se conectar a vários clusters em um único aplicativo Kafka Streams?
NoGuia do desenvolvedor do Kafka Streams [https://docs.confluent.io/current/streams/developer-guide/config-streams.html] diz: Os aplicativos Kafka Streams podem se comunicar apenas com um único cluster Kafka especificado por este valor de ...
O Kafka 0.11.0.0 mantém a redefinição do deslocamento na reinicialização
Estou com um problema com o Kafka 0.11.0.0 Quando crio um novo tópico, insiro os dados fornecidos e os consumo com um consumidor java, depois de reiniciar os desvios do Kafka 0.11.0.0 para o meu grupo de consumidores desaparecer. O tópico ...
ID de rack Kafka e réplicas mínimas em sincronização
Kafka introduziu o ID do rack para fornecer recursos de redundância se um rack inteiro falhar. Há uma configuração mínima de réplica em sincronização para especificar o número mínimo de réplicas que precisam estar sincronizadas antes que um ...