Skip to content

Instantly share code, notes, and snippets.

@jolshan
jolshan / gist:94a6335312ed7af35d77da3abbc6f13b
Last active November 30, 2019 08:23
Example Task Spec for Sticky Partitioner
“task”: {
“type”: “.TaskRole,
“initialDelayMs”: 20000,
“taskSpecs”: {
"bench0": {
"class": "org.apache.kafka.trogdor.workload.ProduceBenchSpec",
"startMs": 0,
"durationMs": 720000,
"producerNode": "node0",
"bootstrapServers": "%{bootstrapServers}",