In config/connect-standalone.properties and config/connect-distributed.properties, there are the following configuration entries:
> key.converter.schemas.enable=false > value.converter.schemas.enable=false But there is no Java source code which uses these two configuration entries. I am talking about kafka_2.11-0.9.0.1. -- Jingguo