kafka-monitor

Xinfra Monitor monitors the availability of Kafka clusters by producing synthetic workloads using end-to-end pipelines to obtain derived vital statistics - E2E latency, service produce/consume availability, offsets commit availability & latency, message loss rate and more.

APACHE-2.0 License

Stars
2K
Committers
28

Bot releases are hidden (Show)

kafka-monitor - 2.2.9

Published by andrewchoi5 over 4 years ago

2.2.9

kafka-monitor - 2.2.8

Published by andrewchoi5 over 4 years ago

2.2.8

kafka-monitor - 2.2.7

Published by andrewchoi5 over 4 years ago

2.2.7

kafka-monitor - 2.2.6

Published by andrewchoi5 over 4 years ago

2.2.6

kafka-monitor - 2.2.5

Published by andrewchoi5 over 4 years ago

2.2.5

kafka-monitor - 2.2.4

Published by andrewchoi5 over 4 years ago

2.2.4

kafka-monitor - 2.2.3

Published by andrewchoi5 over 4 years ago

2.2.3

kafka-monitor - 2.2.2

Published by andrewchoi5 over 4 years ago

2.2.2
scala version update.

kafka-monitor - 2.2.1

Published by andrewchoi5 over 4 years ago

2.2.1

  1. Xinfra Monitor Consumer Group Coordinator Assignment and
  2. Partition Assignments when adding new topic partitions
kafka-monitor - Custom Topic Creation leveraging Xinfra Monitor TopicFactory

Published by andrewchoi5 over 4 years ago

Use createTopicIfNotExist instead of AdminClient (#248)

  1. Use createTopicIfNotExist instead of AdminClient
  2. connects the _topicFactory interface’s createTopicIfNotExist.
kafka-monitor - `MulticlustertopicmanagementService` should block until topic creation.

Published by andrewchoi5 over 4 years ago

  1. Addition of KMF/services/MultiClusterTopicManagementServiceTest.java
  2. Add topic log in consume produce service (#247)
  3. MulticlustertopicmanagementService should block until topic creation
    https://github.com/linkedin/kafka-monitor/compare/2.1.7...master
kafka-monitor - Wait and Block Until CreateTopicsResult Future is complete

Published by andrewchoi5 over 4 years ago

Wait and Block Until CreateTopicsResult Future is complete

kafka-monitor - Fix NoSuchFieldError DEFAULT_SSL_PRINCIPAL_MAPPING_RULES (#239)

Published by andrewchoi5 over 4 years ago

Fix NoSuchFieldError DEFAULT_SSL_PRINCIPAL_MAPPING_RULES (#239)

kafka-monitor - MetricValue casted double to avoid deprecated APIs

Published by andrewchoi5 over 4 years ago

MetricValue casted to double to avoid deprecated APIs.

double recordsDelayedRate = (double) metrics.metrics().get(metrics.metricName("records-delayed-rate", METRIC_GROUP_NAME, tags)).metricValue();

kafka-monitor - Consumer Offset Commit Latency Service Metric Exporting Configs

Published by andrewchoi5 over 4 years ago

This release includes the Consumer Offset Commit Latency Service Metric Exporting Configs in the properties as well as the SingleClusterMonitor

kafka-monitor - Consumer Offset Commit Latency Service & Reporting

Published by andrewchoi5 over 4 years ago

Consumer Offset Commit Latency Service & Reporting

kafka-monitor - KMF Services Sensor Attribute commit-availability-service

Published by andrewchoi5 over 4 years ago

KMF Services Sensor Attribute commit-availability-service

kafka-monitor - Expose offsets-committed-avg in SingleClusterMonitor

Published by andrewchoi5 over 4 years ago

Expose offsets-committed-avg in SingleClusterMonitor

Simplifications of CompletableFuture + Ensuring MultiClusterTopicManagementService performs the topic partitions operations first.
bump up kafka-clients version. (#209)
correct name for offline-runnable-count (#211)
Linkedin's Xinfra Rebranding (#208)

https://github.com/linkedin/kafka-monitor/pull/214