Tag: apache-kafka

Apache Kafka est un système distribué plate-forme de streaming conçu pour stocker et traiter à haut débit de flux de données.

Récupérer le Timestamp de la base de données à partir de Kafka

Kafka Dépendances Maven

Kafka producteur TimeoutException: Expirant 1 dossier(s)

Kafka Zookeeper problèmes de connexion

Sujet ne peut pas être trouvé lors de la production de messages: UNKNOWN_TOPIC_OR_PARTITION

Simple incorporé test Kafka exemple avec spring boot

Kafka Authentification Producteur Impossible de se Connecter Producteur

Kafka démarrage échoue avec zookeeper délai d'attente (serveur distant), mais la machine peut se connecter à zookeeper directement

lire kafka message de départ à partir d'un offset à l'aide de l'API de haut niveau

Kafka“, le module de Connexion n'est pas spécifié dans JAAS config”

Kafka Consommateur abonnement vs partition attribuée

Kafka nouveau producteur délai d'attente

Comment puis-je supprimer un Kafka Groupe de Consommateurs pour réinitialiser les décalages?

erreur lors du démarrage de kafka courtier

Quel est le moyen le plus efficace d'écrire à partir de kafka pour hdfs avec des fichiers de partitionnement dans les dates

kafka nouveau producteur n'est pas en mesure de mettre à jour les métadonnées d'après le courtier est en baisse

Kafka bootstrap-serveurs vs zookeeper dans kafka-console-consommateur

kafka Synchronisation :“java.io.IOException: Trop de fichiers ouverts”

Comment faire pour automatiser le Test Kafka

Kafka consommateur “impossible d'ajouter le chef de file pour les partitions” erreur d'exécution sur Mesos

Kafka Producteur d'erreur qui Expire le 10 enregistrement(s) pour le SUJET:XXXXXX: 6686 ms a passé depuis la création de lots plus s'attarder le temps

Liste de tous les sujets kafka

Confluentes repository Maven ne fonctionne pas?

La lecture des messages compensé en Apache Kafka

Comment équilibrer le Kafka de Leadership?

Kafka - arrêt (kafka.serveur.KafkaServer), les problèmes de démarrage Kafka-Serveur-Start

comment obtenir la reconnaissance de Kafka courtier si le message est produit par le producteur?

Échec de l'exécution de l'objectif org.codehaus.mojo:exec-maven-plugin:1.2.1 - kafka tempête intégration

kafka-console-producteur et script bash

Comment Kafka diffusion à de nombreux Groupes de Consommateurs

Traction Simple Message De La File D'Attente

Est-il possible de vérifier si kafka est en cours d'exécution et kafka-net

Kafka consommateur Spark Streaming

Comment faire pour afficher kafka message

Kafka Utils mal classpath: org.apache.kafka.commun.utils.Utils

Erreur lors de l'exécution de Kafka sur Windows

Activer SSL pour Kafka Clients

ne peut pas se connecter au serveur de kafka

client java exemple de Kafka Producteur, envoyer méthode n'acceptant pas KeyedMessage

Kafka : Comment connecter kafka-console-consommateur pour aller chercher distance courtier contenu de la rubrique?

À l'aide de Kafka java producteur envoyer un message: Producteur de connexion à localhost:9092 échec

CommitFailedException Commettre ne peut pas être terminée, puisque le groupe a déjà rééquilibré et affecté les partitions à un autre membre

la suppression d'un kafka groupe de consommateurs dans zookeeper

Les sujets, les partitions et les touches

Kafka Consommateur la valeur de clé de paire

Erreur de lecture du champ 'topic_metadata': Erreur de lecture sur le tableau de taille 1139567, à seulement 45 octets disponibles

Pourquoi je ne peux pas augmenter la session.délai d'attente.ms?

Comptage du Nombre de messages stockés dans un kafka sujet

Envoie des Objets Java à Kafka Sujet

Comment puis-je instancier un Simulacre de Kafka Sujet pour junit tests?