国产av日韩一区二区三区精品,成人性爱视频在线观看,国产,欧美,日韩,一区,www.成色av久久成人,2222eeee成人天堂

Table des matières
Ajouter les dépendances de Kafka
écrivez un producteur de Kafka
écrivez le consommateur de Kafka
Questions et précautions fréquemment posées
Maison Java javaDidacticiel Comment produire et consommer des messages d'Apache Kafka avec Java?

Comment produire et consommer des messages d'Apache Kafka avec Java?

Jul 11, 2025 am 01:43 AM
java kafka

La clé pour produire et consommer des messages Kafka Apache à l'aide de Java est de configurer correctement les API productrices et de consommateurs et de comprendre leurs processus de base. 1. Ajoutez d'abord les dépendances des clients Kafka pour s'assurer que la version est compatible avec le cluster; 2. Lors de la rédaction de producteurs, configurez Bootstrap.Servers, Key.serializer et Value.Serializer, et créez une instance Kafkaproducer pour envoyer des messages, prêter attention à la fermeture des ressources et au traitement de rappel facultatif; 3. Lorsque vous rédigez des consommateurs, configurez le groupe.id, le désérialiseur, etc., utilisez Kafkaconsumer pour vous abonner à des sujets et extraire des messages dans une boucle, faites attention à la stratégie de soumission des compensations; 4. Les problèmes communs comprennent les conflits de groupe, la soumission inappropriée des compensations et la fermeture incorrecte des ressources, etc. Il est recommandé de tester d'abord le processus de vérification dans un environnement autonome local.

Comment produire et consommer des messages d'Apache Kafka avec Java?

Il n'est en fait pas difficile de produire et de consommer des messages Apache Kafka en Java. Le noyau réside dans la compréhension des concepts de base de Kafka et la ma?trise de l'utilisation des API productrices et de consommateurs. Tant que la configuration est correctement et que la structure du code est claire, l'envoi et la réception de messages peuvent être facilement réalisés.

Comment produire et consommer des messages d'Apache Kafka avec Java?

Ajouter les dépendances de Kafka

Avant de commencer à écrire du code, vous devez introduire la bibliothèque client de Kafka dans votre projet. Si vous utilisez Maven, vous pouvez ajouter les dépendances suivantes dans pom.xml :

 <dépendance>
    <groupId> org.apache.kafka </rombandid>
    <ArtefactId> Kafka-Clients </ Arfactive>
    <version> 3.6.0 </ version>
</Dependance>

Cette version est relativement nouvelle et relativement stable. Bien s?r, vous pouvez également sélectionner la version client correspondante en fonction de votre version de cluster Kafka.

Comment produire et consommer des messages d'Apache Kafka avec Java?

écrivez un producteur de Kafka

La tache du producteur est d'envoyer des messages au sujet de Kafka. Les étapes principales incluent la configuration des propriétés, la création d'une instance de producteur, la création d'un enregistrement de message et l'envoi.

Les éléments de configuration des clés sont:

Comment produire et consommer des messages d'Apache Kafka avec Java?
  • bootstrap.servers : Adresse du courtier Kafka
  • key.serializer et value.serializer : spécifiez la méthode de sérialisation de la clé et de la valeur. StringSerializer est généralement utilisé.

L'exemple de code est le suivant:

 Properties props = news properties ();
propuls.put ("bootstrap.servers", "localhost: 9092");
props.put ("key.serializer", "org.apache.kafka.common.serialization.stringSerializer");
props.put ("value.serializer", "org.apache.kafka.common.serialization.stringSerializer");

Producteur <string, string> producer = new kafkaproducer <> (accessoires);
ProducterRecord <string, string> dissal = new prodorDerRecord <> ("my-topic", "key", "value");

producteur.send (enregistrement);
producteur.close ();

Quelques points à noter:

  • Il est préférable d'appeler close() après avoir envoyé pour éviter la fuite des ressources
  • Si vous souhaitez confirmer si l'envoi est réussi, vous pouvez ajouter la fonction de rappel.Send .send(record, callback)
  • Si c'est juste un test, vous pouvez omettre la clé

écrivez le consommateur de Kafka

Le consommateur est responsable de la lecture des messages du sujet Kafka. Par rapport aux producteurs, la logique du consommateur est un peu plus compliquée car elle nécessite de tirer activement des messages, de traitement des compensations, etc.

Les configurations clés incluent:

  • bootstrap.servers : spécifiez également l'adresse du courtier
  • group.id : ID de groupe de consommateurs doit être défini, sinon une erreur sera signalée
  • key.deserializer et value.deserializer : désérialiseur, généralement en utilisant StringDeserializer

Un processus de consommation simple est le suivant:

 Properties props = news properties ();
propuls.put ("bootstrap.servers", "localhost: 9092");
Prophes.put ("Group.id", "Test-Group");
props.put ("key.deserializer", "org.apache.kafka.common.serialization.stringdeserializer");
props.put ("value.deserializer", "org.apache.kafka.common.serialization.stringdeserializer");

Kafkaconsumer <string, string> Consumer = new Kafkaconsumer <> (accessoires);
Consumer.Subscribe (Collection.SingletonList ("My-Topic"));

while (true) {
    ConsumerCords <String, String> Records = Consumer.Poll (Durée.OfMillis (100));
    for (ConsumerCord <String, String> enregistre: enregistrements) {
        System.out.println ("Re?u:" Record.Value ());
    }
}

Note:

  • poll() tirera un lot de données et les traitera dans une boucle
  • N'oubliez pas de soumettre le décalage après la consommation, vous pouvez choisir de vous soumettre automatiquement ou manuellement
  • Si vous souhaitez consommer une seule fois, puis sortir, vous pouvez casser la boucle après le traitement

Questions et précautions fréquemment posées

Parfois, vous constaterez que le message n'a pas été re?u ou a été consommé à plusieurs reprises, ce qui est généralement causé par les raisons suivantes:

  • Consumer Group.Id Retting Erreur ou conflit
  • Soumettre automatiquement la fréquence de décalage est trop élevée ou trop faible
  • Le non-respect du producteur ou du consommateur entra?ne correctement un statut incohérent
  • Kafka Broker n'est pas démarré ou le réseau n'est pas connecté

Il est recommandé d'exécuter d'abord l'environnement autonome local pendant le développement, puis d'aller au cluster.


Fondamentalement, c'est tout. Le processus de connexion à Kafka en Java n'est pas compliqué, mais certains détails sont faciles à ignorer, tels que la sérialisation, le groupe.ID et les stratégies de soumission. Tant que vous faites attention à la configuration et au processus, vous pouvez fonctionner rapidement.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefa?on, veuillez contacter admin@php.cn

Outils d'IA chauds

Undress AI Tool

Undress AI Tool

Images de déshabillage gratuites

Undresser.AI Undress

Undresser.AI Undress

Application basée sur l'IA pour créer des photos de nu réalistes

AI Clothes Remover

AI Clothes Remover

Outil d'IA en ligne pour supprimer les vêtements des photos.

Clothoff.io

Clothoff.io

Dissolvant de vêtements AI

Video Face Swap

Video Face Swap

échangez les visages dans n'importe quelle vidéo sans effort grace à notre outil d'échange de visage AI entièrement gratuit?!

Article chaud

Outils chauds

Bloc-notes++7.3.1

Bloc-notes++7.3.1

éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise

SublimeText3 version chinoise

Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1

Envoyer Studio 13.0.1

Puissant environnement de développement intégré PHP

Dreamweaver CS6

Dreamweaver CS6

Outils de développement Web visuel

SublimeText3 version Mac

SublimeText3 version Mac

Logiciel d'édition de code au niveau de Dieu (SublimeText3)

Sujets chauds

Tutoriel PHP
1502
276
Comment gérer les transactions en Java avec JDBC? Comment gérer les transactions en Java avec JDBC? Aug 02, 2025 pm 12:29 PM

Pour gérer correctement les transactions JDBC, vous devez d'abord désactiver le mode de validation automatique, puis effectuer plusieurs opérations, et enfin vous engager ou randonner en fonction des résultats; 1. Appelez Conn.SetAutoCommit (false) pour démarrer la transaction; 2. Exécuter plusieurs opérations SQL, telles que l'insertion et la mise à jour; 3. Appelez Conn.Commit () Si toutes les opérations sont réussies, et appelez Conn.Rollback () Si une exception se produit pour garantir la cohérence des données; Dans le même temps, les ressources TRY-With doivent être utilisées pour gérer les ressources, gérer correctement les exceptions et cl?turer les connexions pour éviter la fuite de connexion; De plus, il est recommandé d'utiliser des pools de connexion et de définir des points de sauvegarde pour réaliser un retour en arrière partiel, et de maintenir les transactions aussi courtes que possible pour améliorer les performances.

Comment travailler avec le calendrier à Java? Comment travailler avec le calendrier à Java? Aug 02, 2025 am 02:38 AM

Utilisez des classes dans le package Java.Time pour remplacer les anciennes classes de date et de calendrier; 2. Obtenez la date et l'heure actuelles via LocalDate, LocalDateTime et Localtime; 3. Créez une date et une heure spécifiques en utilisant la méthode OF (); 4. Utilisez la méthode plus / moins pour augmenter et diminuer le temps; 5. Utilisez ZonedDateTime et ZoneID pour traiter le fuseau horaire; 6. Format et cha?nes de date d'analyse via DateTimeFormatter; 7. Utilisez instantanément pour être compatible avec les anciens types de dates si nécessaire; Le traitement des dattes dans le Java moderne devrait donner la priorité à l'utilisation de Java.timeapi, qui fournit clairement, immuable et linéaire

Comparaison des frameworks Java: Spring Boot vs Quarkus vs MicronAut Comparaison des frameworks Java: Spring Boot vs Quarkus vs MicronAut Aug 04, 2025 pm 12:48 PM

Pré-formancetartuptimemoryusage, quarkusandmicronautleadduetocompile-timeprocessingandgraalvsupport, withquarkusofperforming lightbetterine scénarios.

Comment fonctionne la collection Garbage en Java? Comment fonctionne la collection Garbage en Java? Aug 02, 2025 pm 01:55 PM

La collecte des ordures de Java (GC) est un mécanisme qui gère automatiquement la mémoire, ce qui réduit le risque de fuite de mémoire en récupérant des objets inaccessibles. 1. GC juge l'accessibilité de l'objet de l'objet racine (tel que les variables de pile, les threads actifs, les champs statiques, etc.), et les objets inaccessibles sont marqués comme des ordures. 2. Sur la base de l'algorithme de compensation de marque, marquez tous les objets accessibles et effacez des objets non marqués. 3. Adopter une stratégie de collecte générationnelle: la nouvelle génération (Eden, S0, S1) exécute fréquemment MinorGC; Les personnes agées fonctionnent moins, mais prend plus de temps pour effectuer MajorGC; Metaspace Stores Metadata de classe. 4. JVM fournit une variété de périphériques GC: SerialGC convient aux petites applications; Le parallelGC améliore le débit; CMS réduit

Passez l'exemple de l'exemple de journalisation du middleware http Passez l'exemple de l'exemple de journalisation du middleware http Aug 03, 2025 am 11:35 AM

HTTP Log Middleware dans GO peut enregistrer les méthodes de demande, les chemins de requête, la propriété intellectuelle du client et le temps qui prend du temps. 1. Utilisez http.handlerfunc pour envelopper le processeur, 2. Enregistrez l'heure de début et l'heure de fin avant et après l'appel Suivant.Servehttp, 3. Obtenez le vrai client IP via R.RemoteAddr et X-Forwared-For Headers, 4. Utilisez le log.printf aux journaux de demande de sortie, 5. L'exemple de code complet a été vérifié pour s'exécuter et convient au démarrage d'un projet petit et moyen. Les suggestions d'extension incluent la capture des codes d'état, la prise en charge des journaux JSON et le suivi des ID de demande.

Utilisation de types HTML ?Entrée? pour les données utilisateur Utilisation de types HTML ?Entrée? pour les données utilisateur Aug 03, 2025 am 11:07 AM

Le choix du bon type HTMLinput peut améliorer la précision des données, améliorer l'expérience utilisateur et améliorer la convivialité. 1. Sélectionnez les types d'entrée correspondants en fonction du type de données, tels que le texte, le courrier électronique, le tel, le numéro et la date, qui peuvent vérifier automatiquement la somme de la somme et l'adaptation au clavier; 2. Utilisez HTML5 pour ajouter de nouveaux types tels que l'URL, la couleur, la plage et la recherche, qui peuvent fournir une méthode d'interaction plus intuitive; 3. Utilisez l'espace réservé et les attributs requis pour améliorer l'efficacité et la précision du remplissage des formulaires, mais il convient de noter que l'espace réservé ne peut pas remplacer l'étiquette.

Comparaison des outils de construction Java: Maven vs Gradle Comparaison des outils de construction Java: Maven vs Gradle Aug 03, 2025 pm 01:36 PM

GradleisthebetterChoiceFormostNewProjectsDuetOtsSuperiorflexibility, Performance et ModerNtoolingSupport.1.gradle’sgroovy / kotlindslismoreConcis

passer par l'exemple de déclaration de différence expliquée passer par l'exemple de déclaration de différence expliquée Aug 02, 2025 am 06:26 AM

Le report est utilisé pour effectuer des opérations spécifiées avant le retour de la fonction, telles que les ressources de nettoyage; Les paramètres sont évalués immédiatement lorsqu'ils sont reportés et les fonctions sont exécutées dans l'ordre de la dernière entrée (LIFO); 1. Plusieurs éleveurs sont exécutés dans l'ordre inverse des déclarations; 2. Communément utilisé pour le nettoyage sécurisé tel que la fermeture des fichiers; 3. La valeur de retour nommée peut être modifiée; 4. Il sera exécuté même si la panique se produit, adaptée à la récupération; 5. éviter l'abus de report dans les boucles pour éviter la fuite des ressources; Une utilisation correcte peut améliorer la sécurité et la lisibilité du code.

See all articles