apache-kafka
Kafka python API prend-il en charge le traitement des flux?
Kafka Consumer - Comportement du sondage
Kafka producteur TimeoutException: expiration 1 enregistrement (s)
Kafka politique de rétention et de suppression optimale
Kafka Streams avec botte de printemps
Kafka: API de consommateurs vs API de flux
Comment connecter Kafka avec Elasticsearch?
Kafka prend-il en charge la messagerie de demande de réponse?
Comment créer des sujets dans Apache Kafka?
Kafka lève une exception Java.nio.channels.ClosedChannelException
Spring Boot Kafka: impossible de démarrer le consommateur en raison de NoSuchBeanDefinitionException
Comprendre Kafka Sujets et partitions
Comment écrire un fichier dans Kafka Producer
Comment obtenir le dernier décalage d'une partition pour une rubrique kafka?
Kafka - différence entre le décalage de fin de journal (LEO) et le filigrane élevé (HW)
Kafka exception du consommateur et validations de décalage
org.Apache.kafka.common.KafkaException: échec de la construction kafka consumer
kafka a-t-il une interface utilisateur Web par défaut
Comment choisir le nombre de partitions pour une rubrique kafka?
Spring Kafka test d'intégration Erreur lors de l'écriture dans un fichier highwatermark
Quand utiliser ConcurrentKafkaListenerContainerFactory?
Comment vérifier par programme si Kafka Broker est opérationnel dans Python
Comment envoyer des messages clé, valeur avec le producteur de console kafka
Erreur de publication du message dans le sujet Kafka
Limiter la taille des lots Kafka lors de l'utilisation de Spark Streaming
Kafka Connect manque d'espace sur le tas
Kafka - Ce serveur n'est pas le leader de cette partition de sujet
Mode distribué Kafka Connect Le coordinateur de groupe n'est pas disponible
Gérer les mauvais messages à l'aide de l'API Streams de Kafka
Comment envoyer le résultat final de l'agrégation de flux kafka d'un KTable à fenêtre temporelle?
Différence entre KTable et magasin local
Print Kafka Stream Input out to console?
Comment valider manuellement avec Kafka Stream?
Quel est un moyen simple et efficace de déboguer des connecteurs personnalisés Kafka?
Est-il possible d'accéder aux en-têtes de message avec Kafka Streams?
max.poll.intervals.ms défini sur int.Max par défaut
Kafka Streams: utilisez le même `application.id` pour consommer à partir de plusieurs sujets
"La configuration foo.bar a été fournie mais n'est pas une configuration connue"
Kafka Connect - Comment supprimer un connecteur
Kafka Streams - Envoyer sur différents sujets en fonction des données de Streams
Comment envoyer un message à une partition particulière dans Kafka?
Kafka Producteur TimeOutException
Kafka Stream Suppress Session-windowed -gregation
Kafka INVALID_FETCH_SESSION_EPOCH
Pourquoi kafka ne crée pas de sujet? Bootstrap-server n'est pas une option reconnue
Kafka: Utiliser un groupe de consommateurs commun pour accéder à plusieurs sujets
Différence entre l'idempotence et exactement une fois dans Kafka Stream
Comment lire les données en utilisant l'API Kafka Consumer dès le début?
Comment utiliser l'API grand public de Kafka 0.8.2?
Kafka - Mise en œuvre de la file d'attente retardée à l'aide d'un consommateur de haut niveau
Obtenir le dernier message du script de la console consommateur kafka
Kafka comment lire le sujet __consumer_offsets
Consommateur ne recevant pas de messages, console kafka, nouvelle API du consommateur, Kafka 0.9
Plusieurs consommateurs Kafka peuvent-ils lire le même message depuis la partition?
Consommateur Kafka marquant le coordinateur 2147483647 mort
Comment configurer la journalisation pour les producteurs de Kafka?
Comment vérifier si Kafka Server est en cours d'exécution?
Kafka 0.10 Java Client TimeoutException: Lot contenant 1 enregistrement (s) expiré (s)
Comment puis-je obtenir le DERNIER offset d'un sujet kafka?
comprendre l'identifiant du groupe de consommateurs
Kafka bootstrap-servers vs zookeeper dans kafka-console-consumer
Comptage Nombre de messages stockés dans un sujet kafka
La signification de auto.offset.reset et enable.auto.commit dans Kafka n'est pas claire
Comment Kafka stocke-t-il les décalages pour chaque sujet?
Comment reconnaître le décalage actuel au printemps kafka pour un engagement manuel
Spring Kafka - Comment réinitialiser le décalage au plus tard avec un ID de groupe?
Comment écrire pour les consommateurs de Kafka - thread unique vs multi thread
Courtiers leaders sans erreur d'auditeur correspondant dans kafka
La clé est-elle requise lors de l'envoi de messages à Kafka?
Embarqué simple Kafka exemple de test avec démarrage à ressort
Kafka Le consommateur qui récupère les métadonnées pour les sujets a échoué
Kafka dans Docker ne fonctionne pas
Que signifie "Rééquilibrage" dans Apache Kafka contexte?
Spark Streaming - lecture et écriture sur Kafka topic
Kafka Le consommateur obtient une paire de valeurs de clé
Kafka ID de groupe par défaut du consommateur
Supprimer le message après l'avoir consommé dans KAFKA
Kafka10.1 heartbeat.interval.ms, session.timeout.ms et max.poll.interval.ms
Quelle est la différence entre kafka premières et dernières valeurs de décalage
Kafka console consumer ERROR "La validation du décalage a échoué sur la partition"