[CAMEL-7864] The kafka component does not properly support zookeeper chroot configuration

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.13.2
• Fix Version/s: 2.13.3, 2.14.1, 2.15.0
• Component/s: camel-kafka
• Estimated Complexity: Novice
• Assignee: Claus Ibsen
• Reporter: John Shields
• Created: 25/Sep/14 21:18
• Updated: 27/Sep/14 11:24
• Resolved: 27/Sep/14 11:23

Description

The following code in the KafkaConsumer.java file prevents the use of a chroot connection to zookeeper:

        props.put("zookeeper.connect", endpoint.getZookeeperHost() + ":" + endpoint.getZookeeperPort());

I propose simply combining the host and port endpoint properties to a simple "zookeeper.connect" property to give the most flexibility to the end user.