Need to add a custom Kafka connect REST API endpoint to handle events from the DDL parser notification process. https://cwiki.apache.org/confluence/display/KAFKA/KIP-285%3A+Connect+Rest+Extension+Plugin