Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Remove ReplicaSyncingMonitor #635

Merged
merged 1 commit into from
Aug 25, 2022
Merged

Remove ReplicaSyncingMonitor #635

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
53 changes: 1 addition & 52 deletions README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,55 +20,4 @@
3. [Performance Tool ](./docs/performance_benchmark.md): 可模擬多種使用情境來驗證`Kafka`叢集的吞吐量和延遲
4. [快速啟動 Prometheus ](./docs/run_prometheus.md): 建構`Kafka`叢集資訊收集系統
5. [快速啟動 Grafana ](./docs/run_grafana.md): 建置圖形化介面監控`kafka`叢集使用狀況
6. [Web Server](./docs/web_server/README.md): 可透過`Restful APIs`操作`Kafka`叢集
7. [Kafka replica syncing monitor](#Kafka-replica-syncing-monitor): Tracking replica syncing progress. (deprecated)

---

## Kafka Replica Syncing Monitor

This tool will track partition replica syncing progress. This tool can be used to observe
the partition migration process.

### Start monitor syncing progress

```shell
$ ./gradlew run --args="monitor --bootstrap.servers 192.168.103.39:9092"

[2021-11-23T16:00:26.282676667]
Topic "my-topic":
| Partition 0:
| | replica on broker 0 => [####################] 100.00% [leader, synced]
| | replica on broker 2 => [ ] 1.37% 0.00 B/s (unknown) []
| Partition 1:
| | replica on broker 0 => [####################] 100.00% [leader, synced]
| | replica on broker 2 => [ ] 1.35% 0.00 B/s (unknown) []

[2021-11-23T16:00:26.862637796]
Topic "my-topic":
| Partition 0:
| | replica on broker 0 => [####################] 100.00% [leader, synced]
| | replica on broker 2 => [# ] 5.62% 240.54 MB/s (11s estimated) []
| Partition 1:
| | replica on broker 0 => [####################] 100.00% [leader, synced]
| | replica on broker 2 => [# ] 5.25% 242.53 MB/s (12s estimated) []

[2021-11-23T16:00:27.400814839]
Topic "my-topic":
| Partition 0:
| | replica on broker 0 => [####################] 100.00% [leader, synced]
| | replica on broker 2 => [## ] 9.90% 242.53 MB/s (10s estimated) []
| Partition 1:
| | replica on broker 0 => [####################] 100.00% [leader, synced]
| | replica on broker 2 => [## ] 9.13% 240.54 MB/s (11s estimated) []

...
```

### Replica Syncing Monitor Configurations

1. --bootstrap.servers: the server to connect to
2. --interval: the frequency(time interval in second) to check replica state, support floating point value. (default: 1 second)
3. --prop.file: the path to a file that containing the properties to be passed to kafka admin.
4. --topic: topics to track (default: track all non-synced partition by default)
5. --track: keep track even if all the replicas are synced. Also attempts to discover any non-synced replicas. (default: false)
6. [Web Server](./docs/web_server/README.md): 可透過`Restful APIs`操作`Kafka`叢集
2 changes: 0 additions & 2 deletions app/src/main/java/org/astraea/app/App.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import org.astraea.app.admin.ReplicaSyncingMonitor;
import org.astraea.app.automation.Automation;
import org.astraea.app.balancer.BalanceProcessDemo;
import org.astraea.app.performance.Performance;
Expand All @@ -31,7 +30,6 @@ public class App {
private static final Map<String, Class<?>> MAIN_CLASSES =
Map.of(
"performance", Performance.class,
"monitor", ReplicaSyncingMonitor.class,
"automation", Automation.class,
"web", WebService.class,
"balance-demo", BalanceProcessDemo.class);
Expand Down
Loading