Resultados da pesquisa a pedido "apache-kafka"
Como ver a retenção para um tópico específico em kafka
Quero ver o período de retenção definido para um tópico específico. Existe algum comando? Eu tentei combin/kafka-topics.sh --zookeeper hostname:2181 --alter --config retention.ms=172800000 --topic <topic_name> para excluir dados com 2 dias de ...
Compensações armazenadas no Zookeeper ou Kafka?
Estou um pouco confuso sobre onde as compensações são armazenadas ao usar o Kafka e o Zookeeper. Parece que, em alguns casos, as compensações são armazenadas no Zookeeper, em outros casos, armazenadas no Kafka. O que determina se o deslocamento ...
Como obter compensações de grupo de consumidores para partição no Golang Kafka 10
Agora que a biblioteca Golang Kafka (sarama) está fornecendo capacidade de grupo de consumidores sem nenhuma ajuda externa da biblioteca com o kafka 10. Como posso obter o deslocamento da mensagem atual sendo processado por um grupo ...
Obtendo o erro NoClassDefFoundError: org.apache.spark.internal.Logging no Kafka Spark Stream
Estou recebendo um erro no tempo de execução executando abaixo do código java, É necessário incluir alguma dependência para o log como log4js ou algo assim? Por que esse erro não aparece no tempo de compilação para que seja mais fácil? Aqui ...
Problemas de configuração / desempenho do consumidor Kafka
Estou experimentando o kafka como uma alternativa ao AWS SQS. A motivação principal é melhorar o desempenho, onde o kafka eliminaria a restrição de receber 10 mensagens por vez com um limite de 256kb. Aqui está um cenário de alto nível do meu ...
Lendo a mesma mensagem várias vezes de Kafka
eu usoAPI Spring Kafka [http://docs.spring.io/spring-kafka/reference/htmlsingle/#_retrying_deliverieshttp://] implementar o consumidor Kafka com gerenciamento manual de deslocamento: @KafkaListener(topics = "some_topic") public void ...
Kafka - problemas com TimestampExtractor
eu usoorg.apache.kafka:kafka-streams:0.10.0.1 Estou tentando trabalhar com um fluxo baseado em séries temporais que não parece estar acionando umKStream.Process() acionar ("pontuar"). ...
Imprimir entrada Kafka Stream no console?
Eu estive pesquisando muita documentação do Kafka para um aplicativo java no qual estou trabalhando. Tentei entrar na sintaxe lambda introduzida no Java 8, mas sou um pouco superficial nesse assunto e não me sinto muito confiante de que deve ser ...