Resultados da pesquisa a pedido "apache-kafka"
Como verificar se o ZooKeeper está sendo executado ou ativado no prompt de comando?
Eu exploro algumas opções para configurar o kafka e sabia que o tratador deve estar instalado e funcionando para iniciar um kafka. Gostaria de saber como posso encontrar o abaixo. 1) nome do host e porta da minha instância do zookeeper --- ...
alterando o período de retenção kafka durante o tempo de execução
Com o Kafka 0.8.1.1, como altero o tempo de retenção do log enquanto ele está em execução? odocumentação [http://kafka.apache.org/documentation.html#brokerconfigs]diz que a propriedade élog.retention.hours, mas tentando alterá-lo ...
Problema ao conectar kafka de fora
Estou usando hortonwork Sandbox para servidor kafka tentando conectar kafka do eclipse com código java. Use esta configuração para conectar-se ao produtor e enviar a ...
removendo um grupo de consumidores kafka no tratador
Estou usando o kafka_2.9.2-0.8.1.1 com o zookeeper 3.4.6. Existe um utilitário que pode remover automaticamente um grupo de consumidores do tratador? Ou posso simplesmente remover tudo em / customers / [group_id] no tratador? Neste último caso, ...
org.apache.spark.SparkException: tarefa não serializável
Este é um exemplo de código funcional: JavaPairDStream<String, String> messages = KafkaUtils.createStream(javaStreamingContext, zkQuorum, group, topicMap); messages.print(); JavaDStream<String> lines = messages.map(new Function<Tuple2<String, ...
Kafka: Obtenha o host do broker do ZooKeeper
Por razões particulares, preciso usar os dois -ConsumerGroup (também conhecido como consumidor de alto nível) eSimpleConsumer (também conhecido como consumidor de baixo nível) para ler em Kafka. ParaConsumerGroup Eu uso a configuração baseada no ...
Como alterar o deslocamento inicial do tópico?
É possível alterar o deslocamento inicial para um novo tópico? Gostaria de criar um novo tópico e começar a ler a partir do deslocamento10000. Quão?
Deserializador Avro Kafka do Spark Python
Eu criei um fluxo kafka em um aplicativo python spark e posso analisar qualquer texto que o atravesse. kafkaStream = KafkaUtils.createStream(ssc, zkQuorum, "spark-streaming-consumer", {topic: 1})Quero alterar isso para poder analisar mensagens ...
O tratador possui KeeperException, mas Kafka é capaz de criar tópicos e produzir / consumir
Recentemente, configurei o Kafka em um CDH 5 de nó único com o objetivo de jogar com ele em um único nó antes de passar para um cluster real. Inicialmente, eu apenas iniciei o servidor zookeeper, com o servidor kafka e estava tudo bem. Pude ver ...
Falha na obtenção de metadados do consumidor Kafka para tópicos
Estou tentando escrever um cliente Java para os servidores Kafka e ZooKeeper de terceiros. Consigo listar e descrever tópicos, mas quando tento ler algum, umClosedChannelException é criado. Eu os reproduzo aqui com o cliente de linha de ...