Skip to content

Commit dbde642

Browse files
committed
Add kafka connect instrumentation
1 parent 4524f7b commit dbde642

File tree

6 files changed

+590
-0
lines changed

6 files changed

+590
-0
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
muzzle {
2+
pass {
3+
group = "org.apache.kafka"
4+
module = "connect-runtime"
5+
versions = "[0.11.0.0,)"
6+
assertInverse = true
7+
}
8+
}
9+
10+
apply from: "$rootDir/gradle/java.gradle"
11+
12+
dependencies {
13+
compileOnly group: 'org.apache.kafka', name: 'connect-runtime', version: '0.11.0.0'
14+
15+
testImplementation(testFixtures(project(':dd-java-agent:agent-iast')))
16+
testRuntimeOnly project(':dd-java-agent:instrumentation:iast-instrumenter')
17+
testRuntimeOnly project(':dd-java-agent:instrumentation:java-lang')
18+
testRuntimeOnly project(':dd-java-agent:instrumentation:java-io')
19+
testRuntimeOnly project(':dd-java-agent:instrumentation:jackson-core')
20+
testRuntimeOnly project(':dd-java-agent:instrumentation:jackson-core:jackson-core-2.8')
21+
testImplementation(group: 'com.fasterxml.jackson.core', name: 'jackson-databind', version: '2.9.10')
22+
testImplementation group: 'org.assertj', name: 'assertj-core', version: '2.9.+'
23+
testImplementation group: 'org.mockito', name: 'mockito-core', version: '2.19.0'
24+
testImplementation group: 'javax.xml.bind', name: 'jaxb-api', version: '2.2.3'
25+
testImplementation 'org.apache.kafka:connect-api:2.7.0' // Fixed version
26+
testImplementation 'org.apache.kafka:connect-runtime:2.7.0'
27+
testImplementation 'org.apache.kafka:connect-file:2.7.0' // For FileStreamSourceConnector
28+
testImplementation 'org.apache.kafka:kafka-clients:2.7.0'
29+
// Spring Kafka Test library
30+
testImplementation 'org.springframework.kafka:spring-kafka-test:2.7.9' // Version compatible with Kafka 2.7.x
31+
testRuntimeOnly project(':dd-java-agent:instrumentation:kafka-clients-0.11')
32+
}
33+
34+
configurations.testRuntimeClasspath {
35+
// spock-core depends on assertj version that is not compatible with kafka-clients
36+
resolutionStrategy.force 'org.assertj:assertj-core:2.9.1'
37+
}

0 commit comments

Comments
 (0)