Resultados da pesquisa a pedido "kafka-python"
Como passar dados do Kafka para o Spark Streaming?
Estou tentando passar dados de kafka para desencadear streaming. Isto é o que eu fiz até agora: Instalou amboskafka esparkComeçadozookeeper com configuração de propriedades padrãoComeçadokafka server com configuração de propriedades ...
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-python - Como comprometo uma partição?
Usando o kafka-python-1.0.2. Se eu tenho um tópico com 10 partições, como faço para confirmar uma partição específica, enquanto percorre as várias partições e mensagens. Eu simplesmente não consigo encontrar um exemplo disso em qualquer lugar, ...
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 ...