Resultados da pesquisa a pedido "kafka-producer-api"
Política ideal de retenção e exclusão de Kafka
Eu sou bastante novo no kafka, então me perdoe se essa pergunta for trivial. Eu tenho uma configuração muito simples para fins de testes de temporização da seguinte maneira: O computador A -> grava no tópico 1 (Broker) -> o computador B lê do ...
Kafka: alterar o número de partições para um tópico específico usando java
Eu sou novo no Kafka e trabalho com o novo KafkaProducer e KafkaConsumer, versão: 0.9.0.1 Existe alguma maneira no java de alterar / atualizar o número de partições para um tópico específico depois que ele foi criado. Não estou usando o ...
Kafka 0.8.2.2 - Não foi possível publicar mensagens
Escrevemos um cliente java para publicar mensagens no kafka. O código é como mostrado abaixo Properties props = new ...
NoBrokersAvailable: NoBrokersAvailable-Kafka Error
Eu já comecei a aprender Kafka. Tentando operações básicas nele. Entrei em um ponto sobre os "Corretores". Meu kafka está em execução, mas quando eu quero criar uma partição. from kafka import TopicPartition (ERROR THERE) consumer ...
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 ...
O Apache Kafka e o Avro: org.apache.avro.generic.GenericData $ Record não podem ser convertidos em com.harmeetsingh13.java.Customer
Sempre que estou tentando ler a mensagem da fila kafka, recebo a seguinte exceção: [error] (run-main-0) java.lang.ClassCastException: org.apache.avro.generic.GenericData$Record cannot be cast to com.harmeetsingh13.java.Customer ...
Kafka 0.10 Java Client TimeoutException: lote contendo 1 registro (s) expirado
Eu tenho um único nó, multi (3) corretor Zookeeper / Kafka setup. Estou usando o cliente Java Kafka 0.10. Eu escrevi o seguinte produtor remoto simples (em um servidor diferente do Kafka) (no código, substituí meu endereço IP público por ...
Consumidor Java Kafka 0.9.0.1 preso em waititMetadataUpdate ()
Estou tentando fazer com que um simples consumidor Kafka funcione usando a API Java v0.9.0.1. O servidor kafka que estou usando é um contêiner de docker, também executando a versão 0.9.0.1. Abaixo está o código do consumidor: public class ...
Não é possível produzir mensagem para kafka a partir do serviço em execução no docker
Eu tenho um serviço de descanso em execução no contêiner de docker na porta 5000, que é usado para produzir mensagens sobre o tópico kafka que estão ficando sem contêiner de docker. Eu configurei meu cliente produtor com as propriedades abaixo: ...
Compreendendo tópicos e partições Kafka
Estou começando a aprender Kafka para fins de solução corporativa. Durante minhas leituras, algumas perguntas vieram à minha mente: Quando um produtor está produzindo uma mensagem - Ele especificará otemaele quer enviar a mensagem, certo? ...
Página 1 do 2