Ich habe kafka
installiert auf meinem lokalen Server, und durch eine andere Anwendung läuft auf dem Server produers zeigen Überwachung werden die Nachrichten an den Brokern Veröffentlichung innerhalb meines kafka
Server, durch die zookeeper
kann ich leicht sehen Sie die Gesundheit meiner kafka
, die alle Themen in meinem kafka
Server erstellt zeigt, innerhalb von Themen usw. Offset, so nur die zookeeper
ist nicht in der Lage zu zeigen, ist die Nachrichten, die in den einzelnen Themen sind, so jemand empfohlen kafka-manager
Werkzeug, Ich installierte und lief es, es funktionierte gut, es zeigte viele Informationen von meinem kafka
Server, aber immer noch war es nicht in der Lage, echte Nachrichten zu zeigen, die von jeweiligen veröffentlicht oder verbraucht werden Verbraucher in meinem kafka
Server, so meine Frage ist, gibt es einen Weg/Werkzeug/Code, um die veröffentlichten oder verbrauchten Nachrichten zu finden, ich meine, zusätzlich zu diesem kafka-manager
oder ich habe einige Plugins innerhalb der gleichen kafka-manager
installiert, so dass es wird Zeigen Sie auch die jeweiligen Nachrichten. Vielen Dank im Voraus!kafka Nachrichten die eigentlichen Nachrichten veröffentlicht oder verbraucht
0
A
Antwort
1
Ein Kafka-Broker kann Ihnen nicht sagen, wie viele Nachrichten für einen bestimmten Verbraucher zu einem bestimmten Thema konsumiert wurden. Das einzige, was einem Kafka-Broker bekannt ist, ist der aktuelle Log-Offset des Verbrauchers und der aktuelle maximale Offset des Logs. Es kann Ihnen jedoch nicht sagen, wie viele Nachrichten vor dem aktuellen Offset, den der Kunde tatsächlich erhalten hat, da es keine Zähler in der Nähe hat und der Konsument seine eigene Anfangsposition definiert (sowie an verschiedenen Stellen im Protokoll suchen kann).
Sie können diese beiden Nummern mit dem Skript $KAFKA_HOME/bin/kafka-consumer-offset-checker.sh
erhalten.
Verwandte Themen
- 1. Kafka verlorene Nachrichten
- 2. Mein KafkaSpout verbraucht keine Nachrichten von Kafka Brokers in HDP
- 3. Kafka Consumer verbraucht keine Nachrichten von allen Partitionen
- 4. Kafka nicht committed Nachrichten
- 5. Querying kafka Nachrichten
- 6. Dateiring für Kafka-Nachrichten implementieren
- 7. Nachrichten wiederholen sich in kafka
- 8. ActiveMQ get Aus der Warteschleife angenommene oder verbraucht Nachrichten
- 9. spring-cloud-stream-kafka Verbraucht nur die letzten Nachrichten nach dem Start der Anwendung
- 10. Kafka - wie man nach neuen Nachrichten sucht
- 11. UDP-Nachrichten an Kafka senden Thema
- 12. Ich konnte keine Nachrichten an Kafka senden
- 13. Nachrichten konsumieren, ohne von Kafka 10 Consumer
- 14. Anzeigen Nachrichten über Partitionen von Kafka Thema
- 15. Kafka Consumer Lesen von Nachrichten parallel
- 16. Consumer keine Nachrichten, Kafka-Konsole, neue Consumer-API, Kafka 0,9
- 17. Was ist der beste Weg, Nachrichten an Kafka zu veröffentlichen?
- 18. Nachrichten vorkalibrieren, die an Kafka gesendet wurden Thema
- 19. kafka java producer steckt in der herstellung von nachrichten
- 20. Nachrichten sammeln, die nicht erfolgreich auf Kafka geschrieben wurden
- 21. Throttling MSMQ Nachrichten/Priorisierung Nachrichten
- 22. Funken Streaming und Kafka, erhöhen Sie die Anzahl der Nachrichten, die Funken von Kafka
- 23. RabbitMQ Batch-Nachrichten
- 24. Avro-Nachrichten mit Schema
- 25. Kafka connect oder Kafka Client
- 26. Speichert Apache Kafka die Nachrichten intern in HDFS oder einem anderen Dateisystem
- 27. Gmail-Nachrichten automatisch weiterleiten und Nachrichten formatieren?
- 28. Nachrichten-/Ordnerberechtigungen
- 29. Kafka-Produzent erstellt Thema, kann aber keine Nachrichten senden
- 30. Wie Kafka Nachrichten mit Avro und Flink zu entschlüsseln
Versuchen Sie 'bin/kafka-console-consumer.sh' –