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.

Kafka: la rédaction de la coutume de sérialiseur

Est Apache Kafka approprié pour une utilisation comme un non-ordonnée de la tâche de la file d'attente?

Kafka Niveau Élevé de Consommation Récupérer Tous les Messages De Rubrique à l'Aide de l'API Java (Équivalent à --à partir de début)

Courtier d'erreur de réplication “Pas autorisé à accéder aux rubriques: [Topic échec de l'autorisation.] ”

confluentes plate-forme vs apache kafka

Dans Apache Kafka pourquoi ne peut-on pas être plus grand cas que les partitions?

java.lang.NoClassDefFoundError: org/apache/kafka/common/message/KafkaLZ4BlockOutputStream

Kafka Java Producteur avec kerberos

Comment supprimer/nettoyer Kafka messages en file d'attente sans la suppression de Sujet

L'INTERFACE utilisateur de l'outil pour la surveillance de kafka

Comment lire les données à l'aide de Kafka à la Consommation de l'API depuis le début?

Kafka - la Manière la plus Simple pour Obtenir le Dernier Décalage

Comment obtenir les données à partir de vieux décalage de point de Kafka?

Comment utiliser le multi-thread consommateur dans kafka 0.9.0?

NoBrokersAvailable: NoBrokersAvailable-Kafka Erreur

Kafka avoir d'erreur Ne peut être résolu bootstrap url donnée dans le bootstrap serveurs

Quels sont les avantages et les inconvénients de Kafka sur Apache Pulsar

Apache Kafka erreur sur windows - Couldnot de trouver ou charger la classe principale de QuorumPeerMain

Comment vérifier si Kafka Serveur est en cours d'exécution?

org.apache.spark.SparkException: Tâche de ne pas sérialisable

Le suivi de l'INTERFACE utilisateur pour Apache kafka - kafka manager vs kafka moniteur

Quel est le but de Kafka est une paire clé/valeur de messagerie?

IBM MQ rapport à Apache Kafka

Des problèmes avec la période de rétention pour compenser sujet de kafka

Après Linux redémarrer, Kafka lancer “aucun courtage trouvé lors de la tentative de rééquilibrer”

Kafka10.1 battement de coeur.d'intervalle.ms, de la session.délai d'attente.ms et max.sondage.d'intervalle.ms

Zookeeper problème dans la définition de kafka

KeeperErrorCode = NoNode pour /admin/preferred_replica_election

Le marquage de la coordonnatrice de la mort pour le groupe(Kafka)

kafka cant se connecter à zookeeper - FATALE erreur Irrécupérable lors de l'KafkaServerStable de démarrage

La Confusion à propos de supprimer Kafka Sujet

Comment filtrer les messages avant de les transmettre sur les consommateurs?

Comment régler la taille des messages dans Kafka?

Créer plusieurs consommateurs dans Kafka en ligne de commande

la compréhension des consommateurs de l'id de groupe

Pourquoi n'est-ce pas kafka en continuant à travailler sur l'échec de l'un des courtiers?

à l'aide de protocole mqtt avec kafka comme un broker de message

Streamparse wordcount exemple

Ne Kafka soutien priorité pour le sujet ou le message?

comment obtenez-vous par défaut Kafka configs global et par thème à partir de la ligne de commande?

Kafka à la consommation des décalages de gamme avec pas configuré de réinitialisation de la politique pour les partitions

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