kafka_exporter
1.8.0
مصدر كافكا لبروميثيوس. للحصول على مقاييس أخرى من كافكا، قم بإلقاء نظرة على مصدر JMX.
دعم إصدار Apache Kafka 0.10.1.0 (والإصدارات الأحدث).
يمكن تنزيل الملف الثنائي من صفحة الإصدارات.
makemake dockerdocker pull danielqsj/kafka-exporter:latestيمكن استخدامه مباشرة بدلاً من الاضطرار إلى بناء الصورة بنفسك. (Docker Hub danielqsj/kafka-exporter)
kafka_exporter --kafka.server=kafka:9092 [--kafka.server = another-server ...] docker run -ti --rm -p 9308:9308 danielqsj/kafka-exporter --kafka.server=kafka:9092 [--kafka.server=another-server ...]
إنشاء ملف docker-compose.yml يطير
services:
kafka-exporter:
image: danielqsj/kafka-exporter
command: ["--kafka.server=kafka:9092", "[--kafka.server=another-server ...]"]
ports:
- 9308:9308
ثم قم بتشغيله
docker-compose up -d
هذه الصورة قابلة للتكوين باستخدام أعلام مختلفة
| اسم العلم | تقصير | وصف |
|---|---|---|
| kafka.server | كافكا:9092 | عناوين (المضيف: المنفذ) لخادم كافكا |
| kafka.version | 2.0.0 | نسخة وسيط كافكا |
| sasl.enabled | خطأ شنيع | الاتصال باستخدام SASL/PLAIN |
| sasl.handshake | حقيقي | قم بتعيين هذا على خطأ فقط في حالة استخدام وكيل غير Kafka SASL |
| sasl.username | اسم مستخدم SASL | |
| sasl.password | كلمة مرور مستخدم SASL | |
| sasl.mechanism | يمكن أن تكون آلية SASL بسيطة، scram-sha512، scram-sha256 | |
| sasl.service-name | اسم الخدمة عند استخدام Kerberos Auth | |
| sasl.kerberos-config-path | مسار تكوين Kerberos | |
| sasl.realm | عالم كيربيروس | |
| sasl.keytab-path | مسار ملف لوحة المفاتيح Kerberos | |
| sasl.kerberos-auth-type | نوع مصادقة Kerberos. إما "keytabAuth" أو "userAuth" | |
| tls.enabled | خطأ شنيع | اتصل بكافكا باستخدام TLS |
| tls.server-name | يُستخدم للتحقق من اسم المضيف على الشهادات التي تم إرجاعها ما لم يتم تقديم tls.insecure-skip-tls-verify. يجب إعطاء اسم خادم كافكا | |
| tls.ca-ملف | ملف المرجع المصدق الاختياري لمصادقة عميل Kafka TLS | |
| tls.cert-ملف | ملف الشهادة الاختياري لمصادقة عميل كافكا | |
| tls.key-file | ملف المفتاح الاختياري لمصادقة عميل كافكا | |
| tls.insecure-تخطي-tls-التحقق | خطأ شنيع | إذا كان هذا صحيحًا، فلن يتم التحقق من صلاحية شهادة الخادم |
| server.tls.enabled | خطأ شنيع | تمكين TLS لخادم الويب |
| server.tls.mutual-auth-enabled | خطأ شنيع | تمكين المصادقة المتبادلة لعميل TLS |
| server.tls.ca-ملف | ملف المرجع المصدق لخادم الويب | |
| server.tls.cert-ملف | ملف الشهادة لخادم الويب | |
| server.tls.key-file | الملف الرئيسي لخادم الويب | |
| theme.filter | .* | Regex الذي يحدد المواضيع التي سيتم جمعها |
| theme.exclude | ^$ | Regex الذي يحدد المواضيع التي سيتم استبعادها |
| مرشح المجموعة | .* | Regex الذي يحدد مجموعات المستهلكين التي سيتم جمعها |
| استبعاد المجموعة | ^$ | Regex الذي يحدد مجموعات المستهلكين التي سيتم استبعادها |
| web.listen العنوان | :9308 | عنوان للاستماع إليه لواجهة الويب والقياس عن بعد |
| web.telemetry-path | /metrics | المسار الذي يتم من خلاله كشف المقاييس |
| log.enable-sarama | خطأ شنيع | قم بتشغيل تسجيل ساراما |
| use.consumelag.zookeeper | خطأ شنيع | إذا كنت بحاجة إلى استخدام مجموعة من حارس الحديقة |
| Zookeeper.server | المضيف المحلي: 2181 | عنوان (المضيفين) لخادم حديقة الحيوان |
| kafka.labels | اسم مجموعة كافكا | |
| تحديث. البيانات الوصفية | 30 ثانية | الفاصل الزمني لتحديث البيانات التعريفية |
| Offset.show-all | حقيقي | ما إذا كان سيتم عرض الإزاحة/التأخر لجميع مجموعات المستهلكين، أو إظهار مجموعات المستهلكين المتصلة فقط |
| متزامن.تمكين | خطأ شنيع | إذا كان هذا صحيحًا، فإن جميع الخدوش ستؤدي إلى تشغيل عمليات كافكا، وإلا فسوف تشارك النتائج. تحذير: يجب تعطيل هذا في المجموعات الكبيرة |
| theme.workers | 100 | عدد العاملين بالموضوع |
| الإسهاب | 0 | مستوى سجل الإسهاب |
تتم إدارة القيم المنطقية بشكل فريد بواسطة Kingpin. سيكون لكل علامة منطقية مكمل سلبي: -- و --no- .
على سبيل المثال:
إذا كنت بحاجة إلى تعطيل sasl.handshake ، فيمكنك إضافة علامة --no-sasl.handshake
وثائق حول مقاييس بروميثيوس المكشوفة.
للحصول على تفاصيل حول المقاييس الأساسية، يرجى الاطلاع على Apache Kafka.
تفاصيل المقاييس
| اسم | المعلومات المكشوفة |
|---|---|
kafka_brokers | عدد الوسطاء في مجموعة كافكا |
مثال على مخرجات المقاييس
# HELP kafka_brokers Number of Brokers in the Kafka Cluster.
# TYPE kafka_brokers gauge
kafka_brokers 3تفاصيل المقاييس
| اسم | المعلومات المكشوفة |
|---|---|
kafka_topic_partitions | عدد الأقسام لهذا الموضوع |
kafka_topic_partition_current_offset | الإزاحة الحالية للوسيط في الموضوع/القسم |
kafka_topic_partition_oldest_offset | أقدم إزاحة للوسيط في الموضوع/القسم |
kafka_topic_partition_in_sync_replica | عدد النسخ المتماثلة المتزامنة لهذا الموضوع/القسم |
kafka_topic_partition_leader | معرف الوسيط الرئيسي لهذا الموضوع/القسم |
kafka_topic_partition_leader_is_preferred | 1 إذا كان الموضوع/القسم يستخدم الوسيط المفضل |
kafka_topic_partition_replicas | عدد النسخ المتماثلة لهذا الموضوع/القسم |
kafka_topic_partition_under_replicated_partition | 1 إذا كان الموضوع/القسم ضمن منسوخ |
مثال على مخرجات المقاييس
# HELP kafka_topic_partitions Number of partitions for this Topic
# TYPE kafka_topic_partitions gauge
kafka_topic_partitions{topic="__consumer_offsets"} 50
# HELP kafka_topic_partition_current_offset Current Offset of a Broker at Topic/Partition
# TYPE kafka_topic_partition_current_offset gauge
kafka_topic_partition_current_offset{partition="0",topic="__consumer_offsets"} 0
# HELP kafka_topic_partition_oldest_offset Oldest Offset of a Broker at Topic/Partition
# TYPE kafka_topic_partition_oldest_offset gauge
kafka_topic_partition_oldest_offset{partition="0",topic="__consumer_offsets"} 0
# HELP kafka_topic_partition_in_sync_replica Number of In-Sync Replicas for this Topic/Partition
# TYPE kafka_topic_partition_in_sync_replica gauge
kafka_topic_partition_in_sync_replica{partition="0",topic="__consumer_offsets"} 3
# HELP kafka_topic_partition_leader Leader Broker ID of this Topic/Partition
# TYPE kafka_topic_partition_leader gauge
kafka_topic_partition_leader{partition="0",topic="__consumer_offsets"} 0
# HELP kafka_topic_partition_leader_is_preferred 1 if Topic/Partition is using the Preferred Broker
# TYPE kafka_topic_partition_leader_is_preferred gauge
kafka_topic_partition_leader_is_preferred{partition="0",topic="__consumer_offsets"} 1
# HELP kafka_topic_partition_replicas Number of Replicas for this Topic/Partition
# TYPE kafka_topic_partition_replicas gauge
kafka_topic_partition_replicas{partition="0",topic="__consumer_offsets"} 3
# HELP kafka_topic_partition_under_replicated_partition 1 if Topic/Partition is under Replicated
# TYPE kafka_topic_partition_under_replicated_partition gauge
kafka_topic_partition_under_replicated_partition{partition="0",topic="__consumer_offsets"} 0تفاصيل المقاييس
| اسم | المعلومات المكشوفة |
|---|---|
kafka_consumergroup_current_offset | الإزاحة الحالية لمجموعة المستهلكين في الموضوع/القسم |
kafka_consumergroup_lag | التأخر التقريبي الحالي لمجموعة المستهلكين في الموضوع/القسم |
kafka_consumergroupzookeeper_lag_zookeeper | الفارق التقريبي الحالي (حارس الحديقة) لمجموعة المستهلكين في الموضوع/القسم |
لتتمكن من جمع المقاييس kafka_consumergroupzookeeper_lag_zookeeper ، يجب عليك تعيين العلامات التالية:
use.consumelag.zookeeper : تمكين جمع تأخر الاستهلاك من حارس الحديقةzookeeper.server : عنوان الاتصال بـ Zookeeperمثال على مخرجات المقاييس
# HELP kafka_consumergroup_current_offset Current Offset of a ConsumerGroup at Topic/Partition
# TYPE kafka_consumergroup_current_offset gauge
kafka_consumergroup_current_offset{consumergroup="KMOffsetCache-kafka-manager-3806276532-ml44w",partition="0",topic="__consumer_offsets"} -1
# HELP kafka_consumergroup_lag Current Approximate Lag of a ConsumerGroup at Topic/Partition
# TYPE kafka_consumergroup_lag gauge
kafka_consumergroup_lag{consumergroup="KMOffsetCache-kafka-manager-3806276532-ml44w",partition="0",topic="__consumer_offsets"} 1معرف لوحة معلومات Grafana: 7589، الاسم: نظرة عامة على مُصدر كافكا.
للحصول على تفاصيل حول لوحة المعلومات، يرجى الاطلاع على نظرة عامة على Kafka Exporter.
إذا كنت تحب Kafka Exporter، من فضلك أعطني نجمة. سيساعد هذا المزيد من الأشخاص على معرفة مُصدِّر كافكا.
لا تتردد في ارسال لي طلبات السحب.
الشكر موصول لهؤلاء الأشخاص الرائعين:
تبرعك سيشجعني على مواصلة تحسين Kafka Exporter. دعم التبرع Alipay.
الكود مرخص بموجب ترخيص Apache 2.0.
