Resultados da pesquisa a pedido "apache-kafka"
Melhorando o desempenho do Kafka Producer
Estamos executando o apache kafka 0.10.0.xe o Spring 3.xe não podemos usar o spring kafka, pois ele é suportado com o Spring Framework versão 4.x. Portanto, estamos usando a API nativa do Kafka Producer para produzir mensagens. Agora, a ...
O Kafka pode ser fornecido com o LoginModule personalizado para oferecer suporte ao LDAP?
O Kafka pode ser configurado para usar vários mecanismos de autenticação: nome de usuário / senha em texto sem formatação, Kerberos ou SSL. Os dois primeiros usam SASL, onde é necessário um arquivo de configuração JAAS. Para o método de ...
Os trabalhos de conexão dos consumidores estão sendo excluídos ao reiniciar o cluster
Estou enfrentando o problema abaixo ao alterar algumas propriedades relacionadas ao kafka e reiniciar o cluster. In kafka Consumer, there were 5 consumer jobs are running .Se fizermos alguma alteração importante na propriedade e, ao reiniciar o ...
ID de rack Kafka e réplicas mínimas em sincronização
Kafka introduziu o ID do rack para fornecer recursos de redundância se um rack inteiro falhar. Há uma configuração mínima de réplica em sincronização para especificar o número mínimo de réplicas que precisam estar sincronizadas antes que um ...
O Kafka 0.11.0.0 mantém a redefinição do deslocamento na reinicialização
Estou com um problema com o Kafka 0.11.0.0 Quando crio um novo tópico, insiro os dados fornecidos e os consumo com um consumidor java, depois de reiniciar os desvios do Kafka 0.11.0.0 para o meu grupo de consumidores desaparecer. O tópico ...
Fluxos de Apache Kafka Materializar o KTables para um tópico parece lento
Estou usando o fluxo kafka e estou tentando materializar uma KTable em um tópico. Funciona, mas parece ser feito a cada 30 segundos ou mais. Como / quando o Kafka Stream decide materializar o estado atual de uma KTable em um tópico? Existe ...
Como se conectar a vários clusters em um único aplicativo Kafka Streams?
NoGuia do desenvolvedor do Kafka Streams [https://docs.confluent.io/current/streams/developer-guide/config-streams.html] diz: Os aplicativos Kafka Streams podem se comunicar apenas com um único cluster Kafka especificado por este valor de ...
Solicitar mensagens entre dois carimbos de data e hora de Kafka
É possível consumir mensagens de Kafka com base no período em que as mensagens foram ingeridas? Exemplo: Desejo que todas as mensagens sejam ingeridas para um tópico entre 0900-1000 hoje (e agora são 1200). Se houver apenas uma maneira de ...
Aviso de causa UDF: CachedKafkaConsumer não está sendo executado no UninterruptibleThread (KAFKA-1894)
Em um habitualstruct_kafka_wordcount.py [https://gist.github.com/hrchu/2b2590f2f737ef430ac32b7f8edc15c0]código, Quando divido linhas em palavras porudf como abaixo, my_split = udf(lambda x: x.split(' '), ArrayType(StringType())) words ...
Exemplo de teste Kafka incorporado simples com bota de mola
Editar FYI:exemplo de trabalho do gitHub [https://github.com/YunaBraska/embedded-kafka-example] Eu estava pesquisando na Internet e não consegui encontrar um exemplo simples e funcional de um teste Kafka incorporado. Minha configuração é: Bota ...