You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2021/04/20 09:18:42 UTC
[skywalking] branch master updated (527d772 -> 2122990)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git.
from 527d772 SkyWalking support Seata plugin (#6579)
add 2122990 Resolves #6751 - added kafka consumer assign method interception to p… (#6753)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
...terceptor.java => AssignMethodInterceptor.java} | 31 +++++-----
.../kafka/define/KafkaConsumerInstrumentation.java | 22 ++++++-
...rTest.java => AssignMethodInterceptorTest.java} | 28 +++------
.../kafka-scenario/config/expectedData.yaml | 59 ++++++++++++++++++-
.../testcase/kafka/controller/CaseController.java | 67 ++++++++++++++++++++++
6 files changed, 171 insertions(+), 37 deletions(-)
copy apm-sniffer/apm-sdk-plugin/kafka-plugin/src/main/java/org/apache/skywalking/apm/plugin/kafka/{SubscribeMethodInterceptor.java => AssignMethodInterceptor.java} (77%)
copy apm-sniffer/apm-sdk-plugin/kafka-plugin/src/test/java/org/apache/skywalking/apm/plugin/kafka/{SubscribeMethodInterceptorTest.java => AssignMethodInterceptorTest.java} (67%)