mirror of https://github.com/apache/kafka.git
Refactor TopologyTestDriver setup
This commit is contained in:
parent
5d45822e88
commit
4140bc4d16
|
@ -1,64 +0,0 @@
|
|||
{
|
||||
"jfrConfig": {
|
||||
"settings": "profile"
|
||||
},
|
||||
"asyncProfilerConfig": {
|
||||
"jfrsync": true,
|
||||
"alloc": true,
|
||||
"event": "wall",
|
||||
"misc": ""
|
||||
},
|
||||
"file": "$PROJECT_DIR/profile.jfr",
|
||||
"conversionConfig": {
|
||||
"nonProjectPackagePrefixes": [
|
||||
"java.",
|
||||
"javax.",
|
||||
"kotlin.",
|
||||
"jdk.",
|
||||
"com.google.",
|
||||
"org.apache.",
|
||||
"org.spring.",
|
||||
"sun.",
|
||||
"scala."
|
||||
],
|
||||
"enableMarkers": true,
|
||||
"initialVisibleThreads": 10,
|
||||
"initialSelectedThreads": 10,
|
||||
"includeGCThreads": false,
|
||||
"includeInitialSystemProperty": false,
|
||||
"includeInitialEnvironmentVariables": false,
|
||||
"includeSystemProcesses": false,
|
||||
"ignoredEvents": [
|
||||
"jdk.ActiveSetting",
|
||||
"jdk.ActiveRecording",
|
||||
"jdk.BooleanFlag",
|
||||
"jdk.IntFlag",
|
||||
"jdk.DoubleFlag",
|
||||
"jdk.LongFlag",
|
||||
"jdk.NativeLibrary",
|
||||
"jdk.StringFlag",
|
||||
"jdk.UnsignedIntFlag",
|
||||
"jdk.UnsignedLongFlag",
|
||||
"jdk.InitialSystemProperty",
|
||||
"jdk.InitialEnvironmentVariable",
|
||||
"jdk.SystemProcess",
|
||||
"jdk.ModuleExport",
|
||||
"jdk.ModuleRequire"
|
||||
],
|
||||
"minRequiredItemsPerThread": 3
|
||||
},
|
||||
"additionalGradleTargets": [
|
||||
{
|
||||
"targetPrefix": "quarkus",
|
||||
"optionForVmArgs": "-Djvm.args",
|
||||
"description": "Example quarkus config, adding profiling arguments via -Djvm.args option to the Gradle task run"
|
||||
}
|
||||
],
|
||||
"additionalMavenTargets": [
|
||||
{
|
||||
"targetPrefix": "quarkus:",
|
||||
"optionForVmArgs": "-Djvm.args",
|
||||
"description": "Example quarkus config, adding profiling arguments via -Djvm.args option to the Maven goal run"
|
||||
}
|
||||
]
|
||||
}
|
|
@ -493,7 +493,6 @@ public class TopologyTestDriver implements Closeable {
|
|||
streamsMetrics,
|
||||
cache
|
||||
);
|
||||
context.setRecordContext(new ProcessorRecordContext(0L, -1L, -1, null, new RecordHeaders()));
|
||||
|
||||
task = new StreamTask(
|
||||
TASK_ID,
|
||||
|
|
Loading…
Reference in New Issue