{"action":"opened","issue":{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream/issues/1496","repository_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream","labels_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream/issues/1496/labels{/name}","comments_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream/issues/1496/comments","events_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream/issues/1496/events","html_url":"https://github.com/spring-cloud/spring-cloud-stream/issues/1496","id":368061476,"node_id":"MDU6SXNzdWUzNjgwNjE0NzY=","number":1496,"title":"Not able to connect to kafka stream","user":{"login":"bhanu0684","id":42168118,"node_id":"MDQ6VXNlcjQyMTY4MTE4","avatar_url":"https://avatars3.githubusercontent.com/u/42168118?v=4","gravatar_id":"","url":"https://api.github.com/users/bhanu0684","html_url":"https://github.com/bhanu0684","followers_url":"https://api.github.com/users/bhanu0684/followers","following_url":"https://api.github.com/users/bhanu0684/following{/other_user}","gists_url":"https://api.github.com/users/bhanu0684/gists{/gist_id}","starred_url":"https://api.github.com/users/bhanu0684/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/bhanu0684/subscriptions","organizations_url":"https://api.github.com/users/bhanu0684/orgs","repos_url":"https://api.github.com/users/bhanu0684/repos","events_url":"https://api.github.com/users/bhanu0684/events{/privacy}","received_events_url":"https://api.github.com/users/bhanu0684/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2018-10-09T06:40:06Z","updated_at":"2018-10-09T06:40:06Z","closed_at":null,"author_association":"NONE","body":"here is my config file\r\n`spring.cloud.stream:\r\n  bindings:\r\n    greetings-in:\r\n      destination: xemx4rje-default\r\n      binder: kafka1\r\n    greetings-out:\r\n      destination: xemx4rje-default\r\n      binder: kafka1\r\n  binders:\r\n    kafka1:\r\n      type: kafka\r\n      environment:\r\n        spring:\r\n          cloud:\r\n            stream:\r\n              kafka:\r\n                binder.brokers: ark-01.srvs.cloudkafka.com:9094,ark-02.srvs.cloudkafka.com:9094,ark-03.srvs.cloudkafka.com:9094\r\n                binder.jaas.loginModule: com.sun.security.auth.module.ScramLoginModule #org.apache.kafka.common.security.plain.ScramLoginModule\r\n                binder.jaas.options.username: uid\r\n                binder.jaas.options.password: pwd\r\n                binder:\r\n                  configuration:\r\n                    security.protocol: SASL_SSL\r\n                    sasl.mechanism: SCRAM-SHA-256`\r\n\r\nI am getting below error\r\n\r\n2018-10-09 14:36:45.532 ERROR 19316 --- [sk-scheduler-10] o.s.cloud.stream.binding.BindingService  : Failed to create consumer binding; retrying in 30 seconds\r\n\r\norg.springframework.cloud.stream.binder.BinderException: Exception thrown while starting consumer: \r\n\tat org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindConsumer(AbstractMessageChannelBinder.java:326) ~[spring-cloud-stream-2.0.1.RELEASE.jar:2.0.1.RELEASE]\r\n\tat org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindConsumer(AbstractMessageChannelBinder.java:77) ~[spring-cloud-stream-2.0.1.RELEASE.jar:2.0.1.RELEASE]\r\n\tat org.springframework.cloud.stream.binder.AbstractBinder.bindConsumer(AbstractBinder.java:131) ~[spring-cloud-stream-2.0.1.RELEASE.jar:2.0.1.RELEASE]\r\n\tat org.springframework.cloud.stream.binding.BindingService.lambda$rescheduleConsumerBinding$0(BindingService.java:154) ~[spring-cloud-stream-2.0.1.RELEASE.jar:2.0.1.RELEASE]\r\n\tat org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54) ~[spring-context-5.0.9.RELEASE.jar:5.0.9.RELEASE]\r\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:514) ~[na:na]\r\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[na:na]\r\n\tat java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) ~[na:na]\r\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1135) ~[na:na]\r\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[na:na]\r\n\tat java.base/java.lang.Thread.run(Thread.java:844) ~[na:na]\r\nCaused by: org.apache.kafka.common.KafkaException: Failed create new KafkaAdminClient\r\n\tat org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:336) ~[kafka-clients-1.0.2.jar:na]\r\n\tat org.apache.kafka.clients.admin.AdminClient.create(AdminClient.java:61) ~[kafka-clients-1.0.2.jar:na]\r\n\tat org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.createAdminClient(KafkaTopicProvisioner.java:188) ~[spring-cloud-stream-binder-kafka-core-2.0.0.RELEASE.jar:2.0.0.RELEASE]\r\n\tat org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionConsumerDestination(KafkaTopicProvisioner.java:164) ~[spring-cloud-stream-binder-kafka-core-2.0.0.RELEASE.jar:2.0.0.RELEASE]\r\n\tat org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionConsumerDestination(KafkaTopicProvisioner.java:74) ~[spring-cloud-stream-binder-kafka-core-2.0.0.RELEASE.jar:2.0.0.RELEASE]\r\n\tat org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindConsumer(AbstractMessageChannelBinder.java:274) ~[spring-cloud-stream-2.0.1.RELEASE.jar:2.0.1.RELEASE]\r\n\t... 10 common frames omitted\r\nCaused by: org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException: KrbException: Cannot locate default realm\r\n\tat org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:112) ~[kafka-clients-1.0.2.jar:na]\r\n\tat org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:114) ~[kafka-clients-1.0.2.jar:na]\r\n\tat org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:61) ~[kafka-clients-1.0.2.jar:na]\r\n\tat org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:86) ~[kafka-clients-1.0.2.jar:na]\r\n\tat org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:312) ~[kafka-clients-1.0.2.jar:na]\r\n\t... 15 common frames omitted\r\nCaused by: javax.security.auth.login.LoginException: KrbException: Cannot locate default realm\r\n\tat jdk.security.auth/com.sun.security.auth.module.Krb5LoginModule.attemptAuthentication(Krb5LoginModule.java:781) ~[jdk.security.auth:na]\r\n\tat jdk.security.auth/com.sun.security.auth.module.Krb5LoginModule.login(Krb5LoginModule.java:592) ~[jdk.security.auth:na]\r\n\tat java.base/javax.security.auth.login.LoginContext.invoke(LoginContext.java:726) ~[na:na]\r\n\tat java.base/javax.security.auth.login.LoginContext.access$000(LoginContext.java:194) ~[na:na]\r\n\tat java.base/javax.security.auth.login.LoginContext$4.run(LoginContext.java:665) ~[na:na]\r\n\tat java.base/javax.security.auth.login.LoginContext$4.run(LoginContext.java:663) ~[na:na]\r\n\tat java.base/java.security.AccessController.doPrivileged(Native Method) ~[na:na]\r\n\tat java.base/javax.security.auth.login.LoginContext.invokePriv(LoginContext.java:663) ~[na:na]\r\n\tat java.base/javax.security.auth.login.LoginContext.login(LoginContext.java:574) ~[na:na]\r\n\tat org.apache.kafka.common.security.authenticator.AbstractLogin.login(AbstractLogin.java:52) ~[kafka-clients-1.0.2.jar:na]\r\n\tat org.apache.kafka.common.security.authenticator.LoginManager.<init>(LoginManager.java:53) ~[kafka-clients-1.0.2.jar:na]\r\n\tat org.apache.kafka.common.security.authenticator.LoginManager.acquireLoginManager(LoginManager.java:82) ~[kafka-clients-1.0.2.jar:na]\r\n\tat org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:103) ~[kafka-clients-1.0.2.jar:na]\r\n\t... 19 common frames omitted\r\nCaused by: sun.security.krb5.RealmException: KrbException: Cannot locate default realm\r\n\tat java.security.jgss/sun.security.krb5.Realm.getDefault(Realm.java:67) ~[java.security.jgss:na]\r\n\tat java.security.jgss/sun.security.krb5.PrincipalName.<init>(PrincipalName.java:462) ~[java.security.jgss:na]\r\n\tat java.security.jgss/sun.security.krb5.PrincipalName.<init>(PrincipalName.java:471) ~[java.security.jgss:na]\r\n\tat jdk.security.auth/com.sun.security.auth.module.Krb5LoginModule.attemptAuthentication(Krb5LoginModule.java:683) ~[jdk.security.auth:na]\r\n\t... 31 common frames omitted\r\nCaused by: sun.security.krb5.KrbException: Cannot locate default realm\r\n\tat java.security.jgss/sun.security.krb5.Config.getDefaultRealm(Config.java:1155) ~[java.security.jgss:na]\r\n\tat java.security.jgss/sun.security.krb5.Realm.getDefault(Realm.java:63) ~[java.security.jgss:na]\r\n\t... 34 common frames omitted\r\n\r\n\r\n"}}
{"actor":{"display_login":"bhanu0684"}}