public static final String |
CONNECT_INDEX_PROP |
"connect.index" |
public static final String |
CONNECT_PARAMETERS_PROP |
"connect.parameters" |
public static final String |
CONNECT_TYPE_BYTES |
"bytes" |
public static final String |
CONNECT_TYPE_FLOAT32 |
"float32" |
public static final String |
CONNECT_TYPE_FLOAT64 |
"float64" |
public static final String |
CONNECT_TYPE_INT16 |
"int16" |
public static final String |
CONNECT_TYPE_INT32 |
"int32" |
public static final String |
CONNECT_TYPE_INT64 |
"int64" |
public static final String |
CONNECT_TYPE_INT8 |
"int8" |
public static final String |
CONNECT_TYPE_MAP |
"map" |
public static final String |
CONNECT_TYPE_PROP |
"connect.type" |
public static final String |
CONNECT_VERSION_PROP |
"connect.version" |
public static final String |
DEFAULT_ID_PREFIX |
"#id" |
public static final String |
GENERALIZED_TYPE_ENUM |
"org.apache.kafka.connect.data.Enum" |
public static final String |
GENERALIZED_TYPE_UNION |
"org.apache.kafka.connect.data.Union" |
public static final String |
GENERALIZED_TYPE_UNION_FIELD_PREFIX |
"connect_union_field_" |
public static final String |
GENERALIZED_TYPE_UNION_PREFIX |
"connect_union_" |
public static final String |
JSON_ID_PROP |
"io.confluent.connect.json.Id" |
public static final String |
JSON_TYPE_ENUM |
"io.confluent.connect.json.Enum" |
public static final String |
JSON_TYPE_ONE_OF |
"io.confluent.connect.json.OneOf" |
public static final String |
KEY_FIELD |
"key" |
public static final String |
NAMESPACE |
"io.confluent.connect.json" |
public static final String |
NULL_MARKER |
"<NULL>" |
public static final String |
VALUE_FIELD |
"value" |