This is an automated email from the ASF dual-hosted git repository. wusheng pushed a change to branch query-labeled in repository https://gitbox.apache.org/repos/asf/skywalking.git.
from e358683 Query all of labels once selected labels condition is absent. add 5f769ca Add AvgLabeledFunction to ingest multiple labels (#5187) add f9257f5 Provide kafka as collector/reporter (#4847) add 534cff4 Merge branch 'master' into query-labeled No new revisions were added by this update. Summary of changes: .github/workflows/e2e.kafka.yaml | 97 ++++++++++ apm-protocol/apm-network/src/main/proto | 2 +- .../skywalking/apm/agent/core/conf/Config.java | 1 + .../apm/agent/core/jvm/JVMMetricsSender.java | 109 +++++++++++ .../skywalking/apm/agent/core/jvm/JVMService.java | 78 +------- .../apm/agent/core/meter/MeterSender.java | 154 +++++++++++++++ .../apm/agent/core/meter/MeterService.java | 121 ++---------- .../agent/core/profile/ProfileSnapshotSender.java | 126 ++++++++++++ .../core/profile/ProfileTaskChannelService.java | 81 ++------ ...ache.skywalking.apm.agent.core.boot.BootService | 5 +- .../apm/agent/core/boot/ServiceManagerTest.java | 4 +- .../apm/agent/core/meter/MeterServiceTest.java | 9 +- apm-sniffer/config/agent.config | 3 + .../kafka-reporter-plugin/pom.xml | 162 ++++++++++++++++ .../kafka/KafkaContextManagerExtendService.java | 23 +-- .../agent/core/kafka/KafkaJVMMetricsSender.java | 99 ++++++++++ .../apm/agent/core/kafka/KafkaMeterSender.java | 69 +++++++ .../apm/agent/core/kafka/KafkaProducerManager.java | 104 ++++++++++ .../core/kafka/KafkaProfileSnapshotSender.java | 72 +++++++ .../core/kafka/KafkaReporterPluginConfig.java | 48 +++++ .../kafka/KafkaServiceManagementServiceClient.java | 121 ++++++++++++ .../core/kafka/KafkaTraceSegmentServiceClient.java | 84 ++++++++ ...ache.skywalking.apm.agent.core.boot.BootService | 21 +- apm-sniffer/optional-reporter-plugins/pom.xml | 70 +++++++ apm-sniffer/pom.xml | 1 + dist-material/release-docs/LICENSE | 5 + dist-material/release-docs/NOTICE | 17 ++ .../release-docs/licenses/LICENSE-zstd-jni.txt | 26 +++ docs/en/guides/Java-Plugin-Development-Guide.md | 4 +- docs/en/setup/backend/backend-fetcher.md | 50 ++++- docs/en/setup/backend/backend-meter.md | 12 ++ docs/en/setup/backend/backend-receivers.md | 5 +- docs/en/setup/backend/configuration-vocabulary.md | 18 +- docs/en/setup/backend/dynamic-config.md | 6 +- docs/en/setup/backend/trace-sampling.md | 4 +- .../java-agent/How-to-enable-kafka-reporter.md | 18 ++ docs/en/setup/service-agent/java-agent/README.md | 7 + .../agent-analyzer}/pom.xml | 13 +- .../server/analyzer/module/AnalyzerModule.java} | 16 +- .../analyzer/provider/AnalyzerModuleConfig.java} | 10 +- .../analyzer/provider/AnalyzerModuleProvider.java} | 68 +++---- .../provider/jvm}/JVMSourceDispatcher.java | 6 +- .../provider/meter}/config/MeterConfig.java | 2 +- .../provider/meter}/config/MeterConfigs.java | 2 +- .../provider/meter}/config/MeterDataConfig.java | 2 +- .../analyzer/provider/meter}/config/Scope.java | 2 +- .../analyzer/provider/meter}/process/EvalData.java | 2 +- .../provider/meter}/process/EvalHistogramData.java | 2 +- .../provider/meter}/process/EvalMultipleData.java | 2 +- .../provider/meter}/process/EvalSingleData.java | 2 +- .../meter/process/IMeterProcessService.java} | 16 +- .../provider/meter}/process/MeterBuilder.java | 6 +- .../meter}/process/MeterEvalOperation.java | 2 +- .../meter/process/MeterProcessService.java} | 35 ++-- .../provider/meter}/process/MeterProcessor.java | 10 +- .../analyzer/provider/meter}/process/Window.java | 2 +- .../trace}/DBLatencyThresholdsAndWatcher.java | 9 +- .../provider/trace}/TraceSampleRateWatcher.java | 12 +- .../trace}/UninstrumentedGatewaysConfig.java | 9 +- .../parser/ISegmentParserListenerManager.java | 4 +- .../trace}/parser/ISegmentParserService.java | 2 +- .../parser/SegmentParserListenerManager.java | 5 +- .../trace}/parser/SegmentParserServiceImpl.java | 6 +- .../analyzer/provider/trace}/parser/SpanTags.java | 2 +- .../provider/trace}/parser/TraceAnalyzer.java | 18 +- .../trace}/parser/listener/AnalysisListener.java | 2 +- .../parser/listener/AnalysisListenerFactory.java | 6 +- .../parser/listener/EntryAnalysisListener.java | 2 +- .../parser/listener/ExitAnalysisListener.java | 2 +- .../parser/listener/FirstAnalysisListener.java | 2 +- .../parser/listener/LocalAnalysisListener.java | 2 +- .../listener/MultiScopesAnalysisListener.java | 14 +- .../NetworkAddressAliasMappingListener.java | 8 +- .../parser/listener/SegmentAnalysisListener.java | 8 +- .../trace}/parser/listener/SegmentListener.java | 2 +- .../trace}/parser/listener/SourceBuilder.java | 2 +- .../parser/listener/TraceSegmentSampler.java | 4 +- ...ywalking.oap.server.library.module.ModuleDefine | 13 +- ...alking.oap.server.library.module.ModuleProvider | 13 +- .../provider/meter}/process/EvalDataBaseTest.java | 2 +- .../provider/meter}/process/EvalDataTest.java | 2 +- .../meter}/process/EvalHistogramDataTest.java | 2 +- .../meter}/process/EvalMultipleDataTest.java | 7 +- .../meter}/process/EvalSingleDataTest.java | 2 +- .../provider/meter}/process/MeterBaseTest.java | 20 +- .../provider/meter}/process/MeterBuilderTest.java | 10 +- .../meter}/process/MeterEvalOperationTest.java | 5 +- .../meter}/process/MeterProcessContextTest.java | 29 +-- .../meter}/process/MeterProcessorTest.java | 4 +- .../trace}/TraceSampleRateWatcherTest.java | 34 ++-- .../resources/meter-receive-config/config.yaml | 0 .../pom.xml | 22 ++- oap-server/pom.xml | 4 +- oap-server/server-bootstrap/pom.xml | 5 + .../src/main/resources/application.yml | 20 +- .../plugin/zookeeper/ZookeeperCoordinator.java | 10 +- .../meter/function/AvgLabeledFunction.java | 214 +++++++++++++++++++++ .../promethues/PrometheusMetricConverter.java | 38 +++- .../metric/promethues/operation/MetricSource.java | 3 + .../metric/promethues/rule/PrometheusMetric.java | 1 + .../server/core/metric/promethues/rule/Rules.java | 1 + .../meter/function/AvgLabeledFunctionTest.java | 112 +++++++++++ .../kafka-fetcher-plugin}/pom.xml | 18 +- .../agent/kafka/KafkaFetcherHandlerRegister.java | 146 ++++++++++++++ .../agent/kafka/module/KafkaFetcherConfig.java | 82 ++++++++ .../agent/kafka/module/KafkaFetcherModule.java} | 11 +- .../agent/kafka/provider/KafkaFetcherProvider.java | 99 ++++++++++ .../kafka/provider/handler/JVMMetricsHandler.java | 84 ++++++++ .../agent/kafka/provider/handler/KafkaHandler.java | 65 +++++++ .../provider/handler/MeterServiceHandler.java | 68 +++++++ .../kafka/provider/handler/ProfileTaskHandler.java | 79 ++++++++ .../provider/handler/ServiceManagementHandler.java | 135 +++++++++++++ .../provider/handler/TraceSegmentHandler.java | 106 ++++++++++ ...ywalking.oap.server.library.module.ModuleDefine | 13 +- ...alking.oap.server.library.module.ModuleProvider | 13 +- .../agent/kafka/mock/MockModuleManager.java | 50 +++++ .../agent/kafka/mock/MockModuleProvider.java | 46 +++++ .../kafka/provider/KafkaFetcherProviderTest.java | 52 +++++ .../provider/handler/JVMMetricsHandlerTest.java | 110 +++++++++++ .../handler/ServiceManagementHandlerTest.java | 102 ++++++++++ .../provider/handler/SourceReceiverRule.java} | 30 +-- oap-server/server-fetcher-plugin/pom.xml | 1 + .../provider/PrometheusFetcherProvider.java | 3 + .../skywalking-jvm-receiver-plugin/pom.xml | 5 + .../handler/JVMMetricReportServiceHandler.java | 1 + .../skywalking-meter-receiver-plugin/pom.xml | 5 +- .../meter/provider/MeterReceiverProvider.java | 39 ++-- .../provider/handler/MeterServiceHandler.java | 12 +- .../meter/provider/config/MeterConfigsTest.java | 6 +- .../skywalking-trace-receiver-plugin/pom.xml | 5 + .../server/receiver/trace/module/TraceModule.java | 3 +- .../trace/provider/TraceModuleProvider.java | 71 +------ .../v8/grpc/TraceSegmentReportServiceHandler.java | 23 +-- .../rest/TraceSegmentReportBaseServletHandler.java | 20 +- .../rest/TraceSegmentReportListServletHandler.java | 15 +- .../TraceSegmentReportSingleServletHandler.java | 6 +- .../rest/TraceSegmentReportServletHandlerTest.java | 30 ++- .../listener/MultiScopesAnalysisListenerTest.java | 12 +- .../receiver/zipkin/ZipkinReceiverProvider.java | 2 +- .../zipkin/analysis/Receiver2AnalysisBridge.java | 2 +- test/e2e/e2e-test/docker/kafka/Dockerfile.provider | 37 ++++ .../e2e-test/docker/kafka/docker-compose.base.yml | 69 +++++++ .../e2e-test/docker/kafka/docker-compose.meter.yml | 68 +++++++ .../docker/kafka/docker-compose.profiling.yml | 82 ++++++++ test/e2e/e2e-test/docker/kafka/docker-compose.yml | 83 ++++++++ .../{simple/SimpleE2E.java => kafka/KafkaE2E.java} | 76 +++----- .../MeterE2E.java => kafka/KafkaMeterE2E.java} | 27 +-- .../ProfileE2E.java => kafka/KafkaProfileE2E.java} | 23 ++- .../org/apache/skywalking/e2e/meter/MeterE2E.java | 4 +- .../apache/skywalking/e2e/profile/ProfileE2E.java | 4 +- .../apache/skywalking/e2e/simple/SimpleE2E.java | 4 +- .../known-oap-backend-dependencies-es7.txt | 4 + .../known-oap-backend-dependencies.txt | 4 + 153 files changed, 3968 insertions(+), 817 deletions(-) create mode 100644 .github/workflows/e2e.kafka.yaml create mode 100644 apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/jvm/JVMMetricsSender.java create mode 100644 apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/meter/MeterSender.java create mode 100644 apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/profile/ProfileSnapshotSender.java create mode 100644 apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/pom.xml copy oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/module/TraceModule.java => apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaContextManagerExtendService.java (57%) create mode 100644 apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaJVMMetricsSender.java create mode 100644 apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaMeterSender.java create mode 100644 apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaProducerManager.java create mode 100644 apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaProfileSnapshotSender.java create mode 100644 apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaReporterPluginConfig.java create mode 100644 apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaServiceManagementServiceClient.java create mode 100644 apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaTraceSegmentServiceClient.java copy apm-sniffer/{apm-agent-core => optional-reporter-plugins/kafka-reporter-plugin}/src/main/resources/META-INF/services/org.apache.skywalking.apm.agent.core.boot.BootService (50%) create mode 100644 apm-sniffer/optional-reporter-plugins/pom.xml create mode 100644 dist-material/release-docs/licenses/LICENSE-zstd-jni.txt create mode 100644 docs/en/setup/service-agent/java-agent/How-to-enable-kafka-reporter.md copy oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin => analyzer/agent-analyzer}/pom.xml (82%) copy oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/module/TraceModule.java => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/module/AnalyzerModule.java} (67%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/TraceServiceModuleConfig.java => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/AnalyzerModuleConfig.java} (83%) mode change 100755 => 100644 copy oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/TraceModuleProvider.java => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/AnalyzerModuleProvider.java} (66%) mode change 100755 => 100644 rename oap-server/{server-receiver-plugin/skywalking-jvm-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/jvm/provider/handler => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/jvm}/JVMSourceDispatcher.java (98%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/config/MeterConfig.java (93%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/config/MeterConfigs.java (97%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/config/MeterDataConfig.java (95%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/config/Scope.java (94%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalData.java (97%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalHistogramData.java (98%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalMultipleData.java (98%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalSingleData.java (98%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider/MeterReceiverConfig.java => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter/process/IMeterProcessService.java} (71%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterBuilder.java (97%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterEvalOperation.java (97%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider/process/MeterProcessContext.java => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter/process/MeterProcessService.java} (64%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterProcessor.java (95%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/Window.java (98%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/DBLatencyThresholdsAndWatcher.java (87%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/TraceSampleRateWatcher.java (80%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/UninstrumentedGatewaysConfig.java (93%) mode change 100755 => 100644 rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/ISegmentParserListenerManager.java (88%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/ISegmentParserService.java (94%) copy oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/SegmentParserListenerManager.java (91%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/SegmentParserServiceImpl.java (87%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/SpanTags.java (96%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/TraceAnalyzer.java (89%) mode change 100755 => 100644 rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/AnalysisListener.java (95%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/AnalysisListenerFactory.java (81%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/EntryAnalysisListener.java (94%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/ExitAnalysisListener.java (94%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/FirstAnalysisListener.java (94%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/LocalAnalysisListener.java (94%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/MultiScopesAnalysisListener.java (97%) mode change 100755 => 100644 rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/NetworkAddressAliasMappingListener.java (95%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/SegmentAnalysisListener.java (96%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/SegmentListener.java (94%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/SourceBuilder.java (99%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/TraceSegmentSampler.java (91%) copy apm-sniffer/apm-agent-core/src/main/resources/META-INF/services/org.apache.skywalking.apm.agent.core.boot.BootService => oap-server/analyzer/agent-analyzer/src/main/resources/META-INF/services/org.apache.skywalking.oap.server.library.module.ModuleDefine (50%) copy apm-sniffer/apm-agent-core/src/main/resources/META-INF/services/org.apache.skywalking.apm.agent.core.boot.BootService => oap-server/analyzer/agent-analyzer/src/main/resources/META-INF/services/org.apache.skywalking.oap.server.library.module.ModuleProvider (50%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalDataBaseTest.java (97%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalDataTest.java (97%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalHistogramDataTest.java (98%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalMultipleDataTest.java (98%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalSingleDataTest.java (98%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterBaseTest.java (90%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterBuilderTest.java (96%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterEvalOperationTest.java (97%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterProcessContextTest.java (69%) rename oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider => analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterProcessorTest.java (96%) rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/trace/provider => analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/TraceSampleRateWatcherTest.java (81%) copy oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin => analyzer/agent-analyzer}/src/test/resources/meter-receive-config/config.yaml (100%) copy oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin => analyzer}/pom.xml (73%) create mode 100644 oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/meter/function/AvgLabeledFunction.java create mode 100644 oap-server/server-core/src/test/java/org/apache/skywalking/oap/server/core/analysis/meter/function/AvgLabeledFunctionTest.java copy oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin => server-fetcher-plugin/kafka-fetcher-plugin}/pom.xml (72%) create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/KafkaFetcherHandlerRegister.java create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/module/KafkaFetcherConfig.java copy oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/module/TraceModule.java => server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/module/KafkaFetcherModule.java} (73%) create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/KafkaFetcherProvider.java create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/JVMMetricsHandler.java create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/KafkaHandler.java create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/MeterServiceHandler.java create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/ProfileTaskHandler.java create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/ServiceManagementHandler.java create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/TraceSegmentHandler.java copy apm-sniffer/apm-agent-core/src/main/resources/META-INF/services/org.apache.skywalking.apm.agent.core.boot.BootService => oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/resources/META-INF/services/org.apache.skywalking.oap.server.library.module.ModuleDefine (50%) copy apm-sniffer/apm-agent-core/src/main/resources/META-INF/services/org.apache.skywalking.apm.agent.core.boot.BootService => oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/resources/META-INF/services/org.apache.skywalking.oap.server.library.module.ModuleProvider (50%) create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/test/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/mock/MockModuleManager.java create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/test/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/mock/MockModuleProvider.java create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/test/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/KafkaFetcherProviderTest.java create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/test/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/JVMMetricsHandlerTest.java create mode 100644 oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/test/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/ServiceManagementHandlerTest.java rename oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/SegmentParserListenerManager.java => server-fetcher-plugin/kafka-fetcher-plugin/src/test/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/SourceReceiverRule.java} (50%) create mode 100644 test/e2e/e2e-test/docker/kafka/Dockerfile.provider create mode 100644 test/e2e/e2e-test/docker/kafka/docker-compose.base.yml create mode 100644 test/e2e/e2e-test/docker/kafka/docker-compose.meter.yml create mode 100644 test/e2e/e2e-test/docker/kafka/docker-compose.profiling.yml create mode 100644 test/e2e/e2e-test/docker/kafka/docker-compose.yml copy test/e2e/e2e-test/src/test/java/org/apache/skywalking/e2e/{simple/SimpleE2E.java => kafka/KafkaE2E.java} (92%) copy test/e2e/e2e-test/src/test/java/org/apache/skywalking/e2e/{meter/MeterE2E.java => kafka/KafkaMeterE2E.java} (88%) copy test/e2e/e2e-test/src/test/java/org/apache/skywalking/e2e/{profile/ProfileE2E.java => kafka/KafkaProfileE2E.java} (95%)