Última pergunta sobre Apache Kafka
A lista de tarefas do Kafka Connector está vazia
Às vezes, após a inicialização do kafka, recebo esse comportamento (não o tempo todo -parece aleatório).
apache kafka apache kafka connect
Ao usar o relógio de parede, o carimbo de data/hora é passado para um pontuador em milissegundos desde a época do UNIX? (Kafka)
Estou usando o horário do relógio de parede e desejo comparar o carimbo de data/hora passado ao CADE-0 de um pontuador| para um carimbo de data/hora UNIX armazenado em um campo de registro.
apache kafka confluent platform apache kafka streams
Conecte-se a um agente e tópico kafka remoto a partir do nó de extremidade
Estou tentando me conectar a um corretor e tópico kafka remoto para buscar dados. O cliente forneceu o nome do broker kafka remoto, o nome do tópico e o arquivo de propriedade SSL. Quando eu uso os detalhes acima no comando abaixo, ele está funcionando perfeitamente bem.
O que significam os logs de librdkafka.redist
Este é um extrato de um log do console relacionado ao Confluent.Kafka do librdkafka.redist dependency.
apache kafka logging librdkafka confluent platform
O que vários KAFKA_ADVERTISED_LISTENERS significam quando temos apenas um corretor, em comparação com quando temos muitos?
Estou aprendendo Kafka e tentando usá-lo com o docker. Estou confuso ao olhar para os arquivos docker-compose, então queria fazer minhas perguntas aqui.
Como limpar o changelog interno do Kafka KStream e tópicos de repartição
Kafka versão 1.1
apache kafka streams apache kafka
Consumidor do console Docker Kafka Avro -conexão recusada
então estou aprendendo sobre o Kafka e apenas tentando configurá-lo em um ambiente local com a ajuda de um arquivo de composição do docker. Estou seguindo o exemplo de:
confluent platform java apache kafka docker compose
Jar de confluente não sendo reconhecido pelo Eclipse
Eu tenho a dependência abaixo no pom.xml. Posso baixar os dois jars, mas o Eclipse não está reconhecendo o kafka-json-schema-serializer. como posso resolver isso? Eu tentei limpar o projeto e deletar o projeto, reimportá-lo novamente, atualizar o projeto mas sem sucesso Também estou recebendo a mensagem abaixo quando executo a instalação do maven
java maven apache kafka eclipse
Como acessar os logs librdkafka.redist do aplicativo C # que o usa como uma dependência?
Meu log do console do aplicativo mostra muito do seguinte:
Como posso produzir um produtor kafka em Java
Estou tentando criar uma instância java de um produtor Kafka que gera este erro, mas quando executo o produtor do console, ele funciona.
kafka producer api java apache kafka
Kafka para postgres sem conectores kafka
Estou tentando fazer o downstream de dados de tópicos kafka para um banco de dados relacional como o postgres. Não quero usar conectores kafka connect ou jdbc. É de alguma forma que eu possa usar consultas brutas para exportar dados do kafka para o postgres.
python kafka python apache kafka
Qual é a melhor solução para lidar com um grande fluxo de mensagens kafka?
Estou construindo um novo microsserviço que possui dois tópicos kafka que fornecem uma grande pilha de mensagens que precisam ser processadas (o processamento envolve uma chamada REST para outro microsserviço) e republicar uma nova mensagem contendo a mensagem processada. Depois de alguma pesquisa, descobri que posso usar uma das seguintes soluções:
spring kafka apache kafka spring boot reactive kafka apache kafka streams
Como converter o timestamp de Kafka para datetime?
O seguinte mostra uma mensagem recebida. Como converter o carimbo de data/hora em data e hora (python-kafka)?
apache kafka python
Kafka Producer lança InvalidRecordException
Eu tenho o seguinte código do lado do produtor. O tópico Kafka no qual estou publicando tem registro de esquema
kafka producer api spring boot apache kafka spring kafka
Como contar o número de registros (mensagem) no tópico usando kafka-python
Como dito no título, eu quero obter um número de registro no meu tópico e não consigo encontrar uma solução usando a biblioteca kafka-python. Alguém tem alguma ideia?
kafka python python apache kafka
Como configurar dois conjuntos separados de corretores kafka junto com zipkin via fluxo de nuvem de primavera?
Tenho que configurar dois corretores Kafka separados (como no exemplo abaixo) e isso está funcionando muito bem -eu tenho minhas gravações e leituras em Kafkas diferentes.
apache kafka spring zipkin spring boot java
Como usar e testar o Kafka no Quarkus usando Avro como chave e valor de mensagem
Estou tentando usar o[Kafka Quarkus][1] para ler alguns eventos de um tópico e escrever alguns eventos em outro tópico.
avro apache kafka quarkus
Não é possível obter mensagem do tópico kafka criado automaticamente
Tenho o Kafka implantado no OpenShift e há um tópico que é criado automaticamente quando envio uma mensagem em meu aplicativo com spring-kafka. Antes tudo estava bem, mas agora estou mudando para o uso de transações kafka e não consigo receber mensagens do kafka devido a um erro:
spring spring transactions apache kafka
Juntando um fluxo e uma tabela com ksqlDB
Estou tentando ingressar na seguinte tabela KSQL:
ksqldb apache kafka
A execução de docker-compose para a imagem kafka apresenta o erro 'O corretor de conexão recusada pode não estar disponível'
discussão do cliente-admin-kafka| adminclient-1] WARN org.apache.kafka.clients.NetworkClient -[AdminClient clientId=adminclient-1] A conexão com o nó -1 (broker/172.31.0.3: 29092) não pôde ser estabelecida. O corretor pode não estar disponível.
sql spring xcode macos spring boot entity framework datetime ms access networking encryption grails silverlight text data structures c# 4.0 layout google cloud platform pdo scikit learn apache kafka uiviewcontroller path io menu exception handling raspberry pi ftp char webdriver format azure active directory automated tests sonarqube iis 7 ios8 amazon dynamodb jframe firebase cloud messaging cross browser location django admin click vagrant odbc cocoapods rss webserver celery mule task