+ * {
+ "listener_security_protocol_map": {
+ "PLAINTEXT": "PLAINTEXT"
+ },
+ "endpoints": [
+ "PLAINTEXT://10.16.238.94:8092"
+ ],
+ "jmx_port": 8888,
+ "host": "10.16.238.94",
+ "timestamp": "1497505727915",
+ "port": 8092,
+ "version": 4
+ }
+ *
+ *
+ * @param bId broker id
+ * @return SimpleConsumer
+ */
+ @Deprecated
+ public SimpleConsumer getConsumer(int bId) {
+ String jsonString = null;
+ JSONObject brokerInfoJson = null;
+ try {
+ Tuple2