Resultados da pesquisa a pedido "apache-kafka"
UnknownHostException kafka
Estou tentando configurar um cluster Kafka (o primeiro nó no cluster, na verdade). Eu tenho uma configuração de cluster do zookeeper de nó único. Estou configurando o kafka em um nó separado. Ambos rodando o CentOS 6.4, rodando o IPV6, que é um ...
Problema de transmissão do Spark Kafka
Estou usando maven eu adicionei as seguintes dependências <dependency> <!-- Spark dependency --> <groupId>org.apache.spark</groupId> <artifactId>spark-streaming_2.10</artifactId> <version>1.1.0</version> </dependency> <dependency> <!-- Spark ...
Resiliência Kafka - Coordenadora do Grupo
Pelo que entendi, um dos corretores é selecionado como coordenador do grupo, responsável pelo reequilíbrio do consumidor. Discovered coordinator host:9092 (id: 2147483646 rack: null) for group good_groupEu tenho 3 nós com fator de replicação de ...
Como implementar a desserialização no consumidor kafka usando o scala?
Eu tenho a seguinte linha no código do meu consumidor kafka. val lines = KafkaUtils.createStream(ssc, zkQuorum, group, topicpMap).map(_._2) Como desserializar "linhas" desse fluxo no objeto original? A serialisabilidade foi implementada no ...
Como criar um tópico no Kafka através de Java
Quero criar um tópico no Kafka (kafka_2.8.0-0.8.1.1) através do java. Está funcionando bem se eu criar um tópico no prompt de comando e se eu enviar mensagem através da API Java. Mas eu quero criar um tópico através da API Java. Depois de uma ...
Confluent 4.1.0 -> KSQL: junção STREAM-TABLE -> dados da tabela null
PASSO 1: Execute o produtor para criar dados de amostra ./bin/kafka-avro-console-producer \ --broker-list localhost:9092 --topic stream-test-topic \ --property schema.registry.url=http://localhost:8081 ...
Como o reequilíbrio do consumidor funciona em Kafka?
Quando um novo consumidor / colaborador é adicionado ou desativado, o Kafka aciona uma operação de reequilíbrio. O Kafka Rebalancing é uma operação de bloqueio. Os consumidores da Kafka são bloqueados enquanto uma operação de reequilíbrio está em ...
Origem do evento com fluxos Kafka
Estou tentando implementar uma prova de conceito simples de CQRS / sourcing de eventos, além deKafka streams [https://kafka.apache.org/documentation/streams/] (como descrito ...
Número de confirmações e deslocamento em cada partição de um tópico kafka
Como encontrar o número de confirmações e o deslocamento atual em cada partição de umconhecido tópico kafka. Estou usando kafkav0.8.1.1
Como encontrar a versão kafka no linux
Como encontrar a versão kafka no linux? se existe uma maneira de encontrar a versão kafka instalada além de mencionar a versão durante o download?