apache-kafka

J'essaie de travailler avec l'API kafka en java. J'utilise la dépendance maven suivante: <dependency> <groupId ... ais j'essaie de travailler avec lui à distance. Appréciez toute aide et si je peux clarifier du tout, faites-le moi savoir.

J'ai écrit un programme java pour consommer messsage de kafka. Je veux surveiller le décalage de consommation, comment l'obte ... ka</groupId> <artifactId>kafka_2.11</artifactId> <version>0.10.1.1</version> Merci d'avance.

Je suis sur le point d'écrire un prototype pour publier et consommer des messages kafka. Nous avons déjà mis en place une inf ... ement compliqué, et je m'attendais à ce que le Consommateur soit similaire. Il semble aussi que je suis pas seul avec cela.

Je suis nouveau sur kafka. J'essaie d'envoyer un message via l'application java et de le consommer dans l'invite de ligne de ... ic test1 --from-beginning La commande ci-dessus n'affiche rien, aucune erreur, aucune sortie. Où est-ce que je me trompe?

Quels paramètres doivent être envoyés à cette méthode Java: public void resume(Collection<TopicPartition> partitions) ... Java ci-dessus. Est-ce donc 3 paramètres ou 2 ou 1? Veuillez décrire comment dois-je lire ce genre de signatures. Merci.

J'essaie de consommer un message en utilisant l'API JAVA Kafka. suis capable de consommer un message en utilisant kafka-conso ... ssage en utilisant kafka-console-consumer.bat loc zookeeper localhost: 2181 test topic test from depuis le début . Aide-moi

1. Dans mon application qui envoie des données via une connexion TCP (producteur Kafka), j'ai observé une baisse drastique de ... ui (implémentation scala), ce que je ne peux pas comprendre. Par où dois-je commencer pour trouver quel est le problème ici?

J'essaie de configurer confluent kafka v5.4 et d'exécuter l'exportateur prometheus JMX. J'ai trouvé ce blog pour savoir comme ... trics-fullcollector/* io.confluent.support.metrics.SupportedKafka /opt/confluent/confluent-5.4.0/etc/kafka/server.properties

Sto cercando di lavorare con l'API kafka in java. Sto usando la seguente dipendenza maven: <dependency> <group ... a, funziona ma sto cercando di lavorarci da remoto. Apprezzare qualsiasi aiuto e se posso chiarire a tutti fatemelo sapere.

Ho scritto un programma java per consumare messsage da kafka. Voglio monitorare il ritardo di consumo, come ottenerlo da java ... t;/groupId> <artifactId>kafka_2.11</artifactId> <version>0.10.1.1</version> Grazie in anticipo.

Sto per scrivere un prototipo per pubblicare e consumare i messaggi di kafka. Abbiamo già installato un'infrastruttura Cloude ... osa di estremamente complicato, e mi aspettavo che il consumatore fosse simile. Sembra anche che io am non solo con questo.

Sono nuovo di kafka. Sto cercando di inviare un messaggio tramite l'app java e consumarlo nel prompt della riga di comando, m ... --topic test1 --from-beginning Il comando precedente non visualizza nulla, nessun errore, nessun output. Dove mi sbaglio?

Quali parametri devono essere inviati a questo metodo Java: public void resume(Collection<TopicPartition> partitions) ... va sopra. Quindi sono 3 parametri o 2 o 1? Per favore qualcuno descriva come dovrei leggere questo tipo di firme. Grazie.

Sto cercando di consumare il messaggio usando l'API java di Kafka. sono in grado di consumare messaggi usando kafka-console-c ... il messaggio usando kafka-console-consumer.bat local zookeeper localhost:2181 test topic test from from-beginning . Aiutami

1. Nella mia applicazione che invia un dato tramite connessione TCP (Kafka Producer), ho osservato un drastico calo delle pre ... a quando uso quello (implementazione scala), che non riesco a capire. Dove dovrei iniziare a trovare qual è il problema qui?

Sto tentando di configurare confluent kafka v5.4 ed eseguire prometheus JMX exporter. Ho trovato questo blog su come ottenere ... trics-fullcollector/* io.confluent.support.metrics.SupportedKafka /opt/confluent/confluent-5.4.0/etc/kafka/server.properties