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.

Envoyer KafkaProducer partir de la machine locale à hortonworks a sandbox sur virtualbox

Kafka throws java.nio.les canaux.ClosedChannelException

Kafka 0.9 Comment re-consommer message quand manuellement commettre décalage avec une KafkaConsumer

Spark Streaming + Kafka: SparkException: impossible de trouver le chef de file de compensations pour l'Ensemble

Erreur dans l'Édition de message à Kafka sujet

UnknownHostException kafka

KafkaSpout exemple de travail

Comment puis-je obtenir la DERNIÈRE décalage d'un kafka sujet?

Quelle est la différence entre MQTT courtier et Apache Kafka

comment utiliser Kafka 0.8 Log4j appender

Kafka pour zookeeper commande produit d'erreur

test kafka des consommateurs et des producteurs échec de connexion

Requête Kafka sujet d'enregistrements spécifiques

Qu'est-ce que l'utilisation de __consommateur_décalages et _schema sujets de Kafka?

Simple Kafka Consommateur Exemple ne fonctionne pas

Kafka et de règles de pare-feu

Kafka: Comment puis-je activer l'enregistrement de client?

Multiples peuvent Kafka consommateurs lisent même message à partir de la partition

Kafka configuration du serveur - auditeurs vs. annoncés.les auditeurs

Comment enregistrer la dernière compenser cette Étincelle consommée pour ZK ou Kafka et peut lire après le redémarrage

Erreur lors de la création de Kafka Sujets - facteur de Réplication supérieure à la disposition des courtiers

Impossible de Lire l'Artefact Descripteur: IntelliJ

Zookeeper avoir KeeperException mais Kafka en mesure de créer des sujets et de produire/consommer

Erreur: impossible de trouver ou charger la classe principale de config.zookeeper.propriétés

kafka-server-stop.sh ne fonctionne pas lorsque Kafka a commencé à partir d'un script Python

Kafka Consommateur Marquant le coordonnateur 2147483647 morts

Activer JMX sur Kafka Courtiers

Le consommateur ne reçoit pas de messages, kafka console, des consommateurs de nouvelles api, Kafka 0.9

Kafka - Retard dans la File d'attente de la mise en œuvre de haut niveau de consommation

Tempête-Kafka plusieurs becs, comment répartir la charge de travail?

Comment décider Kafka taille de Cluster

Le répertoire n'apache kafka stocker les données dans courtier en nœuds

KafkaUtils classe ne trouve pas dans Spark streaming

Apache Kafka ordre des messages avec plusieurs partitions

Kafka consommateur liste

kafka obtenez la partition de compter pour un sujet

Comment configurer la journalisation pour Kafka producteurs?

Comment faire pour voir la rétention pour un sujet en particulier dans kafka

Apache Kafka est-il une autre API pour JMS?

Exemple d'erreur Apache Kafka: Échec de l'envoi du message après 3 essais

Kafka 0.8, est-il possible de créer un sujet avec une partition et une réplication en utilisant du code Java?

Erreur lors de la création du sujet Kafka: - facteur de réplication plus grand que les courtiers disponibles

Comment obtenir le dernier offset pour une partition pour un sujet kafka?

Commande pour obtenir la liste des courtiers kafka de zookeeper

Exception exécutant kafka-console-producer.sh (0.8.1.1)

Que signifie "Rééquilibrage" dans le contexte d'Apache Kafka?

Kafka - Impossible d'envoyer un message à un serveur distant en utilisant Java

Problème de rééquilibrage lors de la lecture de messages dans Kafka

Sérialiseur par défaut pour kafka 0.8.2.0

Comment obtenir la liste des sujets du serveur kafka à Java