You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@skywalking.apache.org by wu...@apache.org on 2018/01/29 03:09:17 UTC
[incubator-skywalking] 01/01: Merge pull request #772 from
ascrutae/feature/kafka-plugin
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git
commit 9924da71b121e91f22218909bebbfe854ea827f2
Merge: e2d8f62 133470d
Author: 吴晟 Wu Sheng <wu...@foxmail.com>
AuthorDate: Mon Jan 29 11:09:12 2018 +0800
Merge pull request #772 from ascrutae/feature/kafka-plugin
[Agent] Support kafka framework
.../network/trace/component/ComponentsDefine.java | 5 +-
.../apm/agent/core/context/trace/AbstractSpan.java | 2 +
.../core/context/trace/AbstractTracingSpan.java | 6 +
.../apm/agent/core/context/trace/NoopSpan.java | 4 +
apm-sniffer/apm-sdk-plugin/kafka-v1-plugin/pom.xml | 40 ++++++
.../apm/plugin/kafka/v1/CallbackInterceptor.java | 55 ++++++++
.../kafka/v1/ConsumerConstructorInterceptor.java | 34 +++++
.../kafka/v1/ConsumerEnhanceRequiredInfo.java | 53 ++++++++
.../plugin/kafka/v1/KafkaConsumerInterceptor.java | 94 +++++++++++++
.../plugin/kafka/v1/KafkaProducerInterceptor.java | 81 +++++++++++
.../kafka/v1/ProducerConstructorInterceptor.java | 32 +++++
.../v1/ProducerRecordConstructorInterceptor.java | 29 ++++
.../kafka/v1/SubscribeMethodInterceptor.java | 48 +++++++
.../kafka/v1/define/CallbackInstrumentation.java | 69 ++++++++++
.../v1/define/KafkaConsumerInstrumentation.java | 106 +++++++++++++++
.../v1/define/KafkaProducerInstrumentation.java | 91 +++++++++++++
.../v1/define/ProducerRecordInstrumentation.java | 66 +++++++++
.../src/main/resources/skywalking-plugin.def | 4 +
.../plugin/kafka/v11/CallbackInterceptorTest.java | 148 +++++++++++++++++++++
.../v11/ConsumerConstructorInterceptorTest.java | 75 +++++++++++
.../kafka/v11/KafkaConsumerInterceptorTest.java | 142 ++++++++++++++++++++
.../kafka/v11/KafkaProducerInterceptorTest.java | 116 ++++++++++++++++
.../v11/ProducerConstructorInterceptorTest.java | 70 ++++++++++
.../ProducerRecordConstructorInterceptorTest.java | 60 +++++++++
.../kafka/v11/SubscribeMethodInterceptorTest.java | 69 ++++++++++
apm-sniffer/apm-sdk-plugin/pom.xml | 1 +
.../agent/core/context/MockContextSnapshot.java | 47 +++++++
27 files changed, 1546 insertions(+), 1 deletion(-)
--
To stop receiving notification emails like this one, please contact
wusheng@apache.org.