Resultados da pesquisa a pedido "apache-kafka"
Kafka Streams não incrementa o deslocamento em 1 ao produzir para o tópico
Eu implementei um processador de registro de cartas Kafka Dead simple Funciona perfeitamente ao usar registros produzidos pelo produtor do consol No entanto, acho que nossos aplicativos Kafka Streams não garantem que, produzindo registros ...
Como resolver um problema com __consumer_offsets inválidos com ponto de verificação e época do produtor em partições de __transaction_state
Tenho dois tipos de entradas de log no server.log Primeiro tipo: WARN Redefinindo o primeiro deslocamento sujo de__consumer_offsets-6 para registrar o deslocamento 918 desde que ocheckpointed deslocamento 903 é inválido. ...
Como codificar / decodificar mensagens Kafka usando o codificador binário Avro?
Estou tentando usar o Avro para mensagens que estão sendo lidas / gravadas no Kafka. Alguém tem um exemplo de uso do codificador binário Avro para codificar / decodificar dados que serão colocados em uma fila de mensagens? Preciso da parte ...