ti-enxame.com

apache-kafka

Kafka python API suporta o processamento de fluxo?

Consumidor de Kafka - Comportamento de votação

Kafka política ótima de retenção e exclusão

Kafka produtor TimeoutException: expirando 1 registro (s)

Kafka: a mensagem quando serializada é maior que o tamanho máximo de solicitação que você configurou com a configuração max.request.size

Conexão de soquete fechado INFO para o cliente /127.0.0.1:48452 que teve o ID da sessão 0x15698f5ac360001 (org.Apache.zookeeper.server.NIOServerCnxn)

Kafka: API do consumidor versus API do Streams

Como conectar-se Kafka ao Elasticsearch?

Kafka Streams com inicialização por mola

Nenhum serviceName definido no JAAS ou Kafka config (não Kerberos)

Como gravar um arquivo no Kafka Producer

como obter reconhecimento do Kafka broker se a mensagem é produzida pelo produtor?

Como obter o deslocamento mais recente de uma partição para um tópico kafka?

Kafka Dependências do Maven

O Kafka suporta uma solicitação de mensagens de resposta

Como criar tópicos no Apache kafka?

Kafka lança Java.nio.channels.ClosedChannelException

Tópicos, partições e chaves

Entendendo Kafka Tópicos e Partições

Kafka - diferença entre Log end offset (LEO) vs High Watermark (HW))

Por que um consumidor de Kafka demora muito tempo para começar a consumir?

Spring Boot Kafka: Não é possível iniciar o consumidor devido a NoSuchBeanDefinitionException

Kafka exceção do consumidor e confirmações de deslocamento

Erro ao serializar mensagem ao enviar para kafka

Primavera Kafka Repetição do Consumidor

org.Apache.kafka.common.KafkaException: falha ao construir kafka consumidor

kafka tem qualquer interface da web padrão

como definir kafka simultaneidade do consumidor usando a inicialização por mola

Como escolher o número de partições para um tópico kafka?

Como consumir de TopicPartitionOffset específico com Confluent.Kafka no .Net

Spring Kafka Erro ao gravar no arquivo highwatermark

Quando usar ConcurrentKafkaListenerContainerFactory?

Kafka Msg VS REST Chamadas

Como verificar programaticamente se Kafka Broker está instalado e sendo executado em Python

Como enviar mensagens de valor e chave com o produtor do console kafka

kafka Autenticação falhada devido a: Handshake SSL falhou

Kafka Reconexão do consumidor depois de ser desconectado

Como consertar Kafka.common.Errors.TimeoutException: expirando 1 registro (s) xxx ms passado desde a criação de lote plus linger

Erro org.apache.kafka.common.utils.kafkathread - exceção não identificada no thread 'Kafka-Produtor-Rede-Thread

Kafka Producer - org.Apache.kafka.common.serialization.StringSerializer não pôde ser encontrado

Como usar from_json com Kafka connect 0.10 e Spark Streaming Estruturado?

Como salvar o deslocamento mais recente que Spark consumido em ZK ou Kafka e pode ler novamente após a reinicialização

Erro ao publicar mensagem no tópico Kafka

Como enviar o resultado final da agregação kafka-streams de um KTable com janela de tempo?

Imprimir Kafka Entrada de fluxo no console?

Limitar o tamanho dos lotes de Kafka ao usar o Spark Streaming

Kafka simultaneidade de streaming?

Diferença entre Apache Samza e Apache Kafka Streams (foco no paralelismo e comunicação))

Valor ideal para Kafka Conectar o Distributed tasks.max na configuração?

Kafka Conecte ficando sem espaço no heap

Lidando com mensagens ruins usando a API do Kafka Streams

Como confirmar manualmente com o Kafka Stream?

O que é uma maneira simples e eficaz de depurar conectores personalizados Kafka?

É possível acessar cabeçalhos de mensagens com fluxos Kafka?

Kafka - Esse servidor não é o líder dessa partição de tópico

max.poll.intervals.ms definido como int.Max por padrão

Kafka Streams: use o mesmo `application.id` para consumir de vários tópicos

"A configuração foo.bar foi fornecida, mas não é uma configuração conhecida"

Implementar Kafka Streams Processor em .Net?

Kafka Connect - Como excluir um conector

Kafka Streams - Envie em tópicos diferentes, dependendo dos dados do Streams

UnsatisfiedLinkError: /tmp/snappy-1.1.4-libsnappyjava.so Erro ao carregar a biblioteca compartilhada ld-linux-x86-64.so.2: Esse arquivo ou diretório não existe

Como enviar mensagem para uma partição específica no Kafka?

Falha ao excluir o diretório de estado em IDE for Kafka Aplicativo de Fluxo)

Use Kafka Fluxos para exibir dados e processar cada janela de uma só vez

Entendendo kafka grupo de fluxos Por e janela

Kafka suporta Java 10 ou Java 11?

Kafka Connect Modo distribuído O coordenador do grupo não está disponível

Diferença entre o KTable e a loja local

Como conectar o Apache Kafka com o Amazon S3?

Kafka Produtor TimeOutException

Kafka Stream Suprimir sessão-janela-agregação

Kafka INVALID_FETCH_SESSION_EPOCH

Alternativa ao openjdk: 8-Alpine para Kafka Streams

Reiniciar kafka conectar os conectores de coletor e de origem para ler desde o início

Kafka connect: a configuração XXX foi fornecida, mas não é uma configuração conhecida no AdminClientConfig

Por que o kafka não está criando um tópico? Bootstrap-server não é uma opção reconhecida

Kafka Connect - Falha ao liberar, o tempo limite expirou enquanto aguardava que o produtor liberasse as mensagens pendentes

Kafka: use o grupo de consumidores comum para acessar vários tópicos

Diferença entre idempotência e exatamente uma vez em Kafka Stream

Kafka Conecte-se ao Amazon MSK

Como se conectar a um banco de dados Oracle externo no Docker

Erro Serde em Kafka Processo de fluxos com o Spring Cloud Stream

Kafka Streams application Reequilíbrio infinito

Spring Cloud Stream Kafka Fluxos: o número de mensagens downstream não corresponde à soma das mensagens enviadas ao tópico

Um aglutinante padrão foi solicitado, mas não há ligantes disponíveis para 'org.springframework.cloud.stream.messaging.directwithattributscannel'

KAFKA e SSL: Java.Lang.OutOfMemoryError: Java Espaço de heap Ao usar o comando kafka-tópicos em KAFKA cluster SSL

Kafka Stream: "TopicautorizaçãoException: Não autorizado a acessar tópicos" para uma loja interna do estado

Kafka Streams usam casos para adicionar loja global

"A fase de $ Changestream é suportada apenas no erro de conjuntos de réplicas" ao usar o MongoDB-Source-Connect

Como criar programaticamente um tópico no Apache Kafka usando Python

Como o reequilíbrio do consumidor funciona em Kafka?

Erro ao criar o tópico do Kafka: - fator de replicação maior que os corretores disponíveis

Como ler dados usando o Kafka Consumer API desde o começo?

Kafka Algoritmo de reequilíbrio do consumidor

Excluir mensagem após consumi-la em KAFKA

A chave é necessária como parte do envio de mensagens para o Kafka?

Kafka consumidor ao buscar metadados para tópicos falhou

O que significa "Rebalanceamento" no contexto do Apache Kafka?

Spark Streaming - leia e escreva em Kafka topic