[ https://issues.apache.org/jira/browse/KAFKA-3988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17294009#comment-17294009 ]
Ewen Cheslack-Postava commented on KAFKA-3988: ---------------------------------------------- [~pachima...@gmail.com] It's marked WONTFIX because we concluded it didn't make much sense to – as mentioned above, KIP-174 gets rid of the ability to even configure the internal converters. You should remove the internal.converter settings that specify schemas.enable=true. > KafkaConfigBackingStore assumes configs will be stored as schemaless maps > ------------------------------------------------------------------------- > > Key: KAFKA-3988 > URL: https://issues.apache.org/jira/browse/KAFKA-3988 > Project: Kafka > Issue Type: Bug > Components: KafkaConnect > Affects Versions: 0.10.0.0 > Reporter: Ewen Cheslack-Postava > Assignee: Ewen Cheslack-Postava > Priority: Major > Original Estimate: 4h > Remaining Estimate: 4h > > If you use an internal key/value converter that drops schema information (as > is the default in the config files we provide since we use JsonConverter with > schemas.enable=false), the schemas we use that are structs get converted to > maps since we don't know the structure to decode them to. Because our tests > run with these settings, we haven't validated that the code works if schemas > are preserved. > When they are preserved, we'll hit an error message like this > {quote} > [2016-07-25 07:36:34,828] ERROR Found connector configuration > (connector-test-mysql-jdbc) in wrong format: class > org.apache.kafka.connect.data.Struct > (org.apache.kafka.connect.storage.KafkaConfigBackingStore:498) > {quote} > because the code currently checks that it is working with a map. We should > actually be checking for either a Struct or a Map. This same problem probably > affects a couple of other types of data in the same class as Connector > configs, Task configs, Connect task lists, and target states are all Structs. -- This message was sent by Atlassian Jira (v8.3.4#803005)