THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
{
"converter": [
{
"class": "org.apache.kafka.connect.converters.ByteArrayConverter",
"location": "classpath"
}
],
"header_converter": [
{
"class": "org.apache.kafka.connect.storage.SimpleHeaderConverter",
"location": "classpath"
}
],
"sink": [
{
"class": "org.apache.kafka.connect.file.FileStreamSinkConnector",
"location": "classpath"
}
],
"source": [
{
"class": "org.apache.kafka.connect.file.FileStreamSourceConnector",
"location": "classpath",
"version": "3.0.0"
}
],
"transformation": [
{
"class": "com.github.jcustenborder.kafka.connect.transform.common.BytesToString$Key",
"location": "file:/Users/mickael/tmp/path2/kafka-connect-transform-common-0.1.0.14.jar"
},
{
"class": "org.apache.kafka.connect.transforms.DropHeaders",
"location": "classpath"
}
],
"predicate": [
{
"class": "org.apache.kafka.connect.transforms.predicates.HasHeaderKey",
"location": "classpath"
}
]
} |
...