Tag: kafka-consumer-api

Utilisation pour des questions liées à l’Apache Kafka à la consommation de l’API

Limite de Kafka lots de taille lors de l'utilisation de Spark Streaming

La différence entre la session.délai d'attente.ms et max.sondage.d'intervalle.ms pour Kafka 0.10.0.0 et versions ultérieures

Ce n' “Rééquilibrage” dans Apache Kafka contexte?

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

NoBrokersAvailable: NoBrokersAvailable-Kafka Erreur

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

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

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

Comment régler la taille des messages dans Kafka?

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

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

Kafka Dépendances Maven

Kafka producteur TimeoutException: Expirant 1 dossier(s)

Kafka Consommateur abonnement vs partition attribuée

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

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

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?

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

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

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

Kafka throws java.nio.les canaux.ClosedChannelException

KafkaConsumer 0.10 API Java message d'erreur: Aucune affectation actuelle en faveur de la partition

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

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

Kafka et de règles de pare-feu

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

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

Kafka Consommateur Marquant le coordonnateur 2147483647 morts

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

Kafka consommateur liste

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?

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