asf - Revision 1923212: /manifoldcf/trunk/connectors/kafka/connector/src/main/java/org