kazusa
/
skywalking
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Polish log of alert GRPCCallback (#10712)

This commit is contained in:
吴晟 Wu Sheng 2023-04-22 21:24:20 +08:00 committed by GitHub
parent cce87a9917
commit af2cf9958f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
oap-server/server-alarm-plugin/src/main/java/org/apache/skywalking/oap/server/core/alarm/provider/grpc/GRPCCallback.java
View File

@ -143,11 +143,11 @@ public class GRPCCallback implements AlarmCallback {
if (grpcAlarmSetting == null) {
if (grpcClient != null) {
grpcClient.shutdown();
log.debug("gRPC alarm hook target is empty, shutdown the old gRPC client.");
}
alarmServiceStub = null;
alarmSetting = null;
log.warn("gRPC alarm hook settings about host is empty, shutdown the old gRPC client.");
return;
}
@ -155,6 +155,7 @@ public class GRPCCallback implements AlarmCallback {
alarmSetting = grpcAlarmSetting;
if (grpcClient != null) {
grpcClient.shutdown();
log.debug("gRPC alarm hook target is changed, shutdown the old gRPC client.");
}
grpcClient = new GRPCClient(grpcAlarmSetting.getTargetHost(), grpcAlarmSetting.getTargetPort());
grpcClient.connect();

2
test/e2e-v2/cases/virtual-mq/docker-compose.yml
View File

@ -66,7 +66,7 @@ services:
networks:
e2e:
kafka:
image: 'bitnami/kafka:latest'
image: 'bitnami/kafka:2.4.1'
environment:
- KAFKA_BROKER_ID=1
- KAFKA_CFG_LISTENERS=PLAINTEXT://:9092