it-swarm-eu.dev

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: Le message une fois sérialisé est plus grand que la taille de requête maximale que vous avez configurée avec la configuration max.request.size

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?

Sujets, partitions et clés

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

Spring Kafka Consumer Retry

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?

Kafka Msg VS REST Appels

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?

Kafka Streaming simultané?

UnsatisfiedLinkError: /tmp/snappy-1.1.4-libsnappyjava.so Erreur lors du chargement de la bibliothèque partagée ld-linux-x86-64.so.2: aucun fichier ou répertoire de ce type

Différence entre KTable et magasin local

Print Kafka Stream Input out to console?

Différence entre Apache Samza et Apache Kafka Streams (focus sur le parallélisme et la communication)

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 Connect - Échec de vidage, expiration du délai en attendant que le producteur vide les messages en attente

Kafka: Utiliser un groupe de consommateurs commun pour accéder à plusieurs sujets

Différence entre l'idempotence et exactement une fois dans Kafka Stream

Erreur lors de la création du sujet Kafka: - facteur de réplication supérieur à celui des courtiers disponibles

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

Comment faire en sorte que le consommateur de kafka lise depuis le dernier décalage consommé mais pas depuis le début

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 avec .Net Client

Kafka 0.10 Java Client TimeoutException: Lot contenant 1 enregistrement (s) expiré (s)

Comment puis-je obtenir le DERNIER offset d'un sujet kafka?

comment définir le nom du groupe lors de la consommation de messages dans kafka à l'aide de la ligne de commande

Kafka Obtenir une erreur Aucune URL d'amorçage pouvant être résolue donnée dans les serveurs d'amorçage

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?

Spring Kafka Producer n'envoie pas à Kafka 1.0.0 (Magic v1 ne prend pas en charge les en-têtes d'enregistrement)

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 liste de consommateurs

Kafka dans Docker ne fonctionne pas

Que signifie "Rééquilibrage" dans Apache Kafka contexte?

Spark Streaming - lecture et écriture sur Kafka topic

Différence entre session.timeout.ms et max.poll.interval.ms pour Kafka 0.10.0.0 et versions ultérieures

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

Kafka et règles de pare-feu

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"

Pourquoi les consommateurs Kafka produisent-ils INVALID_FETCH_SESSION_Epoch après la mise à jour vers 1.1?

Kafka consommateur pour plusieurs sujets

Kafka définir le type de compression au producteur vs sujet

Test d'un @KafkaListener à l'aide de Spring Embedded Kafka

différence entre groupid et consumerid dans Kafka consumer