{"action":"created","issue":{"url":"https://api.github.com/repos/confluentinc/kafka-rest/issues/113","labels_url":"https://api.github.com/repos/confluentinc/kafka-rest/issues/113/labels{/name}","comments_url":"https://api.github.com/repos/confluentinc/kafka-rest/issues/113/comments","events_url":"https://api.github.com/repos/confluentinc/kafka-rest/issues/113/events","html_url":"https://github.com/confluentinc/kafka-rest/issues/113","id":108831839,"number":113,"title":"NoSuchElementException exception","user":{"login":"inadler","id":9049727,"avatar_url":"https://avatars.githubusercontent.com/u/9049727?v=3","gravatar_id":"","url":"https://api.github.com/users/inadler","html_url":"https://github.com/inadler","followers_url":"https://api.github.com/users/inadler/followers","following_url":"https://api.github.com/users/inadler/following{/other_user}","gists_url":"https://api.github.com/users/inadler/gists{/gist_id}","starred_url":"https://api.github.com/users/inadler/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/inadler/subscriptions","organizations_url":"https://api.github.com/users/inadler/orgs","repos_url":"https://api.github.com/users/inadler/repos","events_url":"https://api.github.com/users/inadler/events{/privacy}","received_events_url":"https://api.github.com/users/inadler/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":1,"created_at":"2015-09-29T09:35:28Z","updated_at":"2015-10-07T21:19:11Z","closed_at":null,"body":"I have a new cluster with 5 brokers, 5 zookeepers and 5 proxies.\r\nI can push messages using the proxies but when I try to consume, I get the bellow exception in the consume response.\r\nWhat am I missing?\r\n\r\nHTTP/1.1 500 Internal Server Error\r\nContent-Length: 4976\r\nContent-Type: application/vnd.kafka.binary.v1+json\r\nServer: Jetty(8.1.16.v20140903)\r\n\r\n{\"error_code\":500,\"message\":\"Internal Server Error java.util.NoSuchElementException: None.get\\njava.util.NoSuchElementException: None.get\r\nat scala.None$.get(Option.scala:313)\r\nat scala.None$.get(Option.scala:311)\r\nat io.confluent.kafkarest.MetadataObserver.extractPartitionsFromZKData(MetadataObserver.java:154)\r\nat io.confluent.kafkarest.MetadataObserver.getTopicsData(MetadataObserver.java:105)\r\nat io.confluent.kafkarest.MetadataObserver.getTopics(MetadataObserver.java:74)\r\nat io.confluent.kafkarest.MetadataObserver.topicExists(MetadataObserver.java:81)\r\nat io.confluent.kafkarest.ConsumerManager.readTopic(ConsumerManager.java:205)\r\nat io.confluent.kafkarest.resources.ConsumersResource.readTopic(ConsumersResource.java:142)\r\nat io.confluent.kafkarest.resources.ConsumersResource.readTopicBinary(ConsumersResource.java:119)\r\nat sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source)\r\nat sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\r\nat java.lang.reflect.Method.invoke(Method.java:606)\r\nat org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory$1.invoke(ResourceMethodInvocationHandlerFactory.java:81)\r\nat org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:151)\r\nat org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:171)\r\nat org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$VoidOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:136)\r\nat org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:104)\r\nat org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:406)\r\nat org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:350)\r\nat org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:106)\r\nat org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:259)\r\nat org.glassfish.jersey.internal.Errors$1.call(Errors.java:271)\r\nat org.glassfish.jersey.internal.Errors$1.call(Errors.java:267)\r\nat org.glassfish.jersey.internal.Errors.process(Errors.java:315)\r\nat org.glassfish.jersey.internal.Errors.process(Errors.java:297)\r\nat org.glassfish.jersey.internal.Errors.process(Errors.java:267)\r\nat org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:319)\r\nat org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:236)\r\nat org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:1028)\r\nat org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:373)\r\nat org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:381)\r\nat org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:344)\r\nat org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:219)\r\nat org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:684)\r\nat org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:503)\r\nat org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:229)\r\nat org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1086)\r\nat org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:429)\r\nat org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:193)\r\nat org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1020)\r\nat org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:135)\r\nat org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:154)\r\nat org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116)\r\nat org.eclipse.jetty.server.Server.handle(Server.java:370)\r\nat org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:494)\r\nat org.eclipse.jetty.server.AbstractHttpConnection.headerComplete(AbstractHttpConnection.java:971)\r\nat org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.headerComplete(AbstractHttpConnection.java:1033)\r\nat org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:644)\r\nat org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:235)\r\nat org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82)\r\nat org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:696)\r\nat org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:53)\r\nat org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608)\r\nat org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543)\r\nat java.lang.Thread.run(Thread.java:745)\\n\"}\r\n"},"comment":{"url":"https://api.github.com/repos/confluentinc/kafka-rest/issues/comments/146332696","html_url":"https://github.com/confluentinc/kafka-rest/issues/113#issuecomment-146332696","issue_url":"https://api.github.com/repos/confluentinc/kafka-rest/issues/113","id":146332696,"user":{"login":"kjvalencik","id":2471970,"avatar_url":"https://avatars.githubusercontent.com/u/2471970?v=3","gravatar_id":"","url":"https://api.github.com/users/kjvalencik","html_url":"https://github.com/kjvalencik","followers_url":"https://api.github.com/users/kjvalencik/followers","following_url":"https://api.github.com/users/kjvalencik/following{/other_user}","gists_url":"https://api.github.com/users/kjvalencik/gists{/gist_id}","starred_url":"https://api.github.com/users/kjvalencik/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/kjvalencik/subscriptions","organizations_url":"https://api.github.com/users/kjvalencik/orgs","repos_url":"https://api.github.com/users/kjvalencik/repos","events_url":"https://api.github.com/users/kjvalencik/events{/privacy}","received_events_url":"https://api.github.com/users/kjvalencik/received_events","type":"User","site_admin":false},"created_at":"2015-10-07T21:19:11Z","updated_at":"2015-10-07T21:19:11Z","body":"I believe this is the same as: https://github.com/confluentinc/kafka-rest/issues/105"}}