{"action":"created","issue":{"url":"https://api.github.com/repos/Symantec/kafka-security-0.9/issues/1","repository_url":"https://api.github.com/repos/Symantec/kafka-security-0.9","labels_url":"https://api.github.com/repos/Symantec/kafka-security-0.9/issues/1/labels{/name}","comments_url":"https://api.github.com/repos/Symantec/kafka-security-0.9/issues/1/comments","events_url":"https://api.github.com/repos/Symantec/kafka-security-0.9/issues/1/events","html_url":"https://github.com/Symantec/kafka-security-0.9/issues/1","id":158583853,"number":1,"title":"TOPIC_AUTHORIZATION_FAILED","user":{"login":"pmdcosta","id":6930401,"avatar_url":"https://avatars.githubusercontent.com/u/6930401?v=3","gravatar_id":"","url":"https://api.github.com/users/pmdcosta","html_url":"https://github.com/pmdcosta","followers_url":"https://api.github.com/users/pmdcosta/followers","following_url":"https://api.github.com/users/pmdcosta/following{/other_user}","gists_url":"https://api.github.com/users/pmdcosta/gists{/gist_id}","starred_url":"https://api.github.com/users/pmdcosta/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/pmdcosta/subscriptions","organizations_url":"https://api.github.com/users/pmdcosta/orgs","repos_url":"https://api.github.com/users/pmdcosta/repos","events_url":"https://api.github.com/users/pmdcosta/events{/privacy}","received_events_url":"https://api.github.com/users/pmdcosta/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":6,"created_at":"2016-06-06T00:38:56Z","updated_at":"2016-06-13T08:56:07Z","closed_at":null,"body":"Hi, I have followed the steps in README, but I am getting the following error, in both the producer and consumer :\r\n```\r\n[2016-06-06 10:35:35,592] WARN Error while fetching metadata with correlation id 0 : {test=TOPIC_AUTHORIZATION_FAILED} (org.apache.kafka.clients.NetworkClient)\r\n[2016-06-06 10:35:35,681] WARN Error while fetching metadata with correlation id 1 : {test=TOPIC_AUTHORIZATION_FAILED} (org.apache.kafka.clients.NetworkClient)\r\n[2016-06-06 10:35:35,784] WARN Error while fetching metadata with correlation id 2 : {test=TOPIC_AUTHORIZATION_FAILED} (org.apache.kafka.clients.NetworkClient)\r\n[2016-06-06 10:35:35,886] WARN Error while fetching metadata with correlation id 3 : {test=TOPIC_AUTHORIZATION_FAILED} (org.apache.kafka.clients.NetworkClient)\r\n...\r\n```\r\n\r\nKafka logs also show errors:\r\n```\r\n[2016-06-06 10:26:08,702] INFO Registered broker 0 at path /brokers/ids/0 with addresses: SSL -> EndPoint(c7001.symantec.dev.com,9093,SSL) (kafka.utils.ZkUtils)\r\n[2016-06-06 10:26:08,705] INFO Kafka version : 0.9.0.1 (org.apache.kafka.common.utils.AppInfoParser)\r\n[2016-06-06 10:26:08,705] INFO Kafka commitId : 23c69d62a0cabf06 (org.apache.kafka.common.utils.AppInfoParser)\r\n[2016-06-06 10:26:08,706] INFO [Kafka Server 0], started (kafka.server.KafkaServer)\r\n[2016-06-06 10:26:08,932] ERROR [KafkaApi-0] error when handling request Name:UpdateMetadataRequest;Version:1;Controller:0;ControllerEpoch:1;CorrelationId:0;ClientId:0;AliveBrokers:0 : (EndPoint(c7001.symantec.dev.com,9093,SSL));PartitionState: (kafka.server.KafkaApis)\r\nkafka.common.ClusterAuthorizationException: Request Request(0,192.168.70.101:9093-192.168.70.101:60583,Session(User:CN=c7001.symantec.dev.com,OU=test,O=test,L=test,ST=test,C=test,c7001.symantec.dev.com/192.168.70.101),null,1465172768903,SSL) is not authorized.\r\n\tat kafka.server.KafkaApis.authorizeClusterAction(KafkaApis.scala:910)\r\n\tat kafka.server.KafkaApis.handleUpdateMetadataRequest(KafkaApis.scala:158)\r\n\tat kafka.server.KafkaApis.handle(KafkaApis.scala:74)\r\n\tat kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)\r\n\tat java.lang.Thread.run(Thread.java:745)\r\n[2016-06-06 10:26:38,614] ERROR [KafkaApi-0] error when handling request Name:LeaderAndIsrRequest;Version:0;Controller:0;ControllerEpoch:1;CorrelationId:1;ClientId:0;Leaders:BrokerEndPoint(0,c7001.symantec.dev.com,9093);PartitionState:(test,0) -> (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:1),AllReplicas:0) (kafka.server.KafkaApis)\r\nkafka.common.ClusterAuthorizationException: Request Request(0,192.168.70.101:9093-192.168.70.101:60583,Session(User:CN=c7001.symantec.dev.com,OU=test,O=test,L=test,ST=test,C=test,c7001.symantec.dev.com/192.168.70.101),null,1465172798607,SSL) is not authorized.\r\n\tat kafka.server.KafkaApis.authorizeClusterAction(KafkaApis.scala:910)\r\n\tat kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:113)\r\n\tat kafka.server.KafkaApis.handle(KafkaApis.scala:72)\r\n\tat kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)\r\n\tat java.lang.Thread.run(Thread.java:745)\r\n[2016-06-06 10:26:38,617] ERROR [KafkaApi-0] error when handling request Name:UpdateMetadataRequest;Version:1;Controller:0;ControllerEpoch:1;CorrelationId:2;ClientId:0;AliveBrokers:0 : (EndPoint(c7001.symantec.dev.com,9093,SSL));PartitionState:[test,0] -> (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:1),AllReplicas:0) (kafka.server.KafkaApis)\r\nkafka.common.ClusterAuthorizationException: Request Request(0,192.168.70.101:9093-192.168.70.101:60583,Session(User:CN=c7001.symantec.dev.com,OU=test,O=test,L=test,ST=test,C=test,c7001.symantec.dev.com/192.168.70.101),null,1465172798616,SSL) is not authorized.\r\n\tat kafka.server.KafkaApis.authorizeClusterAction(KafkaApis.scala:910)\r\n\tat kafka.server.KafkaApis.handleUpdateMetadataRequest(KafkaApis.scala:158)\r\n\tat kafka.server.KafkaApis.handle(KafkaApis.scala:74)\r\n\tat kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)\r\n\tat java.lang.Thread.run(Thread.java:745)\r\n[2016-06-06 10:26:46,552] INFO Processing notification(s) to /kafka-acl-changes (kafka.common.ZkNodeChangeNotificationListener)\r\n```\r\n\r\nAny idea what could be happening ?"},"comment":{"url":"https://api.github.com/repos/Symantec/kafka-security-0.9/issues/comments/225524261","html_url":"https://github.com/Symantec/kafka-security-0.9/issues/1#issuecomment-225524261","issue_url":"https://api.github.com/repos/Symantec/kafka-security-0.9/issues/1","id":225524261,"user":{"login":"reiabreu","id":906018,"avatar_url":"https://avatars.githubusercontent.com/u/906018?v=3","gravatar_id":"","url":"https://api.github.com/users/reiabreu","html_url":"https://github.com/reiabreu","followers_url":"https://api.github.com/users/reiabreu/followers","following_url":"https://api.github.com/users/reiabreu/following{/other_user}","gists_url":"https://api.github.com/users/reiabreu/gists{/gist_id}","starred_url":"https://api.github.com/users/reiabreu/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/reiabreu/subscriptions","organizations_url":"https://api.github.com/users/reiabreu/orgs","repos_url":"https://api.github.com/users/reiabreu/repos","events_url":"https://api.github.com/users/reiabreu/events{/privacy}","received_events_url":"https://api.github.com/users/reiabreu/received_events","type":"User","site_admin":false},"created_at":"2016-06-13T08:56:07Z","updated_at":"2016-06-13T08:56:07Z","body":"I had notice the missing space and issued the correct command. I'll try it again and get back to you."}}
{"actor":{"display_login":"reiabreu"}}