Support Map and List as Headers - Fixed tests
@@ -181,10 +181,6 @@ public class CamelSourceTask extends SourceTask {
record.headers().addTime(keyCamelHeader, (Time)value);
} else if (value instanceof Timestamp) {
record.headers().addTimestamp(keyCamelHeader, (Timestamp)value);
- } else if (value instanceof Map) {
- record.headers().addMap(keyCamelHeader, (Map)value, Schema.STRING_SCHEMA);
- } else if (value instanceof List) {
- record.headers().addList(keyCamelHeader, (List)value, SchemaBuilder.array(Schema.STRING_SCHEMA));
}
}
}
