public String kafkaUri ( ) { return String . format ( "kafka://%s?topic=%s&groupId=%s&zookeeperHost=%s&zookeeperPort=%d&serializerClass=%s&keySerializerClass=%s" , kafkaBrokerList , topicName , groupId , zookeeperHost , zookeeperPort , StringEncoder . class . getName ( ) , StringEncoder . class . getName ( ) ) ; }
Returns a kafka connection uri