Resultados da pesquisa a pedido "apache-kafka"
Kafka: escrevendo serializador personalizado
Estou tentando criar um POC com o Kafka 0.8.1. Estou usando minha própria classe java como uma mensagem Kafka que possui vários tipos de dados String. Não posso usar a classe serializador padrão ou a classe Stringizer que vem com a biblioteca ...
Erro de exemplo do Apache Kafka: falha ao enviar mensagem após 3 tentativas
Estou executando este exemplo de produtor kafka mencionado em seu site O código: public class TestProducer { public static void main(String[] args) { long events = Long.parseLong(args[0]); Random rnd = new Random(); Properties props = ...
Quando / como um tópico "marcado para exclusão" é finalmente removido?
Emiti o comando para excluir um tópico: ./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic vip_ips_alerts Pareceu dar uma resposta feliz: [2014-05-31 20:58:10,112] INFO zookeeper state changed ...
Adicionando um conector ao Kafka Connect
Estou usando a imagem Confluent Kafka Docker, especificamente usando ...
Falha ao gravar dados de deslocamento no zookeeper no kafka-storm
Eu estava configurando um cluster de tempestade para calcular tendências em tempo real e outras estatísticas, no entanto, tenho alguns problemas ao introduzir o recurso de "recuperação" neste projeto, permitindo o deslocamento que foi lido pela ...
Reiniciar um consumidor Kafka (python) consome todas as mensagens na fila novamente
Estou usando o Kafka 0.8.1 e o Kafka python-0.9.0. Na minha configuração, tenho 2 corretores kafka. Quando executo meu consumidor kafka, posso vê-lo recuperando mensagens da fila e acompanhando as compensações para os dois corretores. ...
Como escrever para os consumidores Kafka - single threaded vs multi threaded
Eu escrevi um único consumidor Kafka (usando o Spring Kafka), que lê de um único tópico e faz parte de um grupo de consumidores. Depois que uma mensagem é consumida, ela executa todas as operações a jusante e passa para o próximo deslocamento da ...
Como expor o método Java para Kafka (commitSync com partições) no Scala?
Eu estou tentando expor o método Java via Scala (mais detalhes sobre o método java original - é proveniente deKafka [https://kafka.apache.org/0101/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync(java.util.Map)] ) Este é o ...
Como obter a lista de tópicos do servidor kafka em Java
estou usandokafka 0.8 versão e muito novo para ele. Quero conhecer a lista de tópicos criados emkafka server junto com seus metadados. Existe alguma API disponível para descobrir isso? Basicamente, preciso escrever um consumidor Java que deve ...
Problema do tratador na definição de kafka
Para instalar o kafka, baixei a pasta tar do kafka. Para iniciar o servidor, tentei este comando: bin/zookeeper-server-start.sh config/zookeeper.propertiesO seguinte erro ocorreu ao inserir o comando acima: INFO Reading configuration from: ...