Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- After manually create topic:
- 2020-02-05 09:18:23.736 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.3.1
- 2020-02-05 09:18:23.736 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 18a913733fb71c01
- 2020-02-05 09:18:23.736 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1580869103736
- 2020-02-05 09:18:24.007 WARN 12305 --- [ask-scheduler-2] o.s.c.s.b.k.p.KafkaTopicProvisioner : No partitions have been retrieved for the topic (SINGAPORE_RECEIVER). This will affect the health check.
- 2020-02-05 09:18:25.010 WARN 12305 --- [ad | producer-5] org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-5] Error while fetching metadata with correlation id 8 : {SINGAPORE_RECEIVER=TOPIC_AUTHORIZATION_FAILED}
- 2020-02-05 09:18:25.010 ERROR 12305 --- [ad | producer-5] org.apache.kafka.clients.Metadata : [Producer clientId=producer-5] Topic authorization failed for topics [SINGAPORE_RECEIVER]
- 2020-02-05 09:18:25.010 ERROR 12305 --- [ask-scheduler-2] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to obtain partition information
- org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [SINGAPORE_RECEIVER]
- 2020-02-05 09:18:25.011 INFO 12305 --- [ask-scheduler-2] o.a.k.clients.admin.AdminClientConfig : AdminClientConfig values:
- bootstrap.servers = [localhost:9090]
- client.dns.lookup = default
- client.id =
- connections.max.idle.ms = 300000
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- receive.buffer.bytes = 65536
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 120000
- retries = 5
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = [hidden]
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = SCRAM-SHA-512
- security.protocol = SASL_SSL
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- 2020-02-05 09:18:25.013 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.3.1
- 2020-02-05 09:18:25.013 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 18a913733fb71c01
- 2020-02-05 09:18:25.013 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1580869105013
- 2020-02-05 09:18:25.213 WARN 12305 --- [ask-scheduler-2] o.s.c.s.b.k.p.KafkaTopicProvisioner : No partitions have been retrieved for the topic (SINGAPORE_RECEIVER). This will affect the health check.
- 2020-02-05 09:18:26.218 WARN 12305 --- [ad | producer-5] org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-5] Error while fetching metadata with correlation id 9 : {SINGAPORE_RECEIVER=TOPIC_AUTHORIZATION_FAILED}
- 2020-02-05 09:18:26.218 ERROR 12305 --- [ad | producer-5] org.apache.kafka.clients.Metadata : [Producer clientId=producer-5] Topic authorization failed for topics [SINGAPORE_RECEIVER]
- 2020-02-05 09:18:26.218 ERROR 12305 --- [ask-scheduler-2] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to obtain partition information
- org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [SINGAPORE_RECEIVER]
- 2020-02-05 09:18:26.219 INFO 12305 --- [ask-scheduler-2] o.a.k.clients.admin.AdminClientConfig : AdminClientConfig values:
- bootstrap.servers = [localhost:9090]
- client.dns.lookup = default
- client.id =
- connections.max.idle.ms = 300000
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- receive.buffer.bytes = 65536
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 120000
- retries = 5
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = [hidden]
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = SCRAM-SHA-512
- security.protocol = SASL_SSL
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- 2020-02-05 09:18:26.222 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.3.1
- 2020-02-05 09:18:26.223 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 18a913733fb71c01
- 2020-02-05 09:18:26.223 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1580869106222
- 2020-02-05 09:18:26.459 WARN 12305 --- [ask-scheduler-2] o.s.c.s.b.k.p.KafkaTopicProvisioner : No partitions have been retrieved for the topic (SINGAPORE_RECEIVER). This will affect the health check.
- 2020-02-05 09:18:27.463 WARN 12305 --- [ad | producer-5] org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-5] Error while fetching metadata with correlation id 10 : {SINGAPORE_RECEIVER=TOPIC_AUTHORIZATION_FAILED}
- 2020-02-05 09:18:27.463 ERROR 12305 --- [ad | producer-5] org.apache.kafka.clients.Metadata : [Producer clientId=producer-5] Topic authorization failed for topics [SINGAPORE_RECEIVER]
- 2020-02-05 09:18:27.463 ERROR 12305 --- [ask-scheduler-2] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to obtain partition information
- org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [SINGAPORE_RECEIVER]
- 2020-02-05 09:18:27.464 INFO 12305 --- [ask-scheduler-2] o.a.k.clients.admin.AdminClientConfig : AdminClientConfig values:
- bootstrap.servers = [localhost:9090]
- client.dns.lookup = default
- client.id =
- connections.max.idle.ms = 300000
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- receive.buffer.bytes = 65536
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 120000
- retries = 5
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = [hidden]
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = SCRAM-SHA-512
- security.protocol = SASL_SSL
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- 2020-02-05 09:18:27.465 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.3.1
- 2020-02-05 09:18:27.465 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 18a913733fb71c01
- 2020-02-05 09:18:27.466 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1580869107465
- 2020-02-05 09:18:27.686 WARN 12305 --- [ask-scheduler-2] o.s.c.s.b.k.p.KafkaTopicProvisioner : No partitions have been retrieved for the topic (SINGAPORE_RECEIVER). This will affect the health check.
- 2020-02-05 09:18:28.688 WARN 12305 --- [ad | producer-5] org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-5] Error while fetching metadata with correlation id 11 : {SINGAPORE_RECEIVER=TOPIC_AUTHORIZATION_FAILED}
- 2020-02-05 09:18:28.689 ERROR 12305 --- [ad | producer-5] org.apache.kafka.clients.Metadata : [Producer clientId=producer-5] Topic authorization failed for topics [SINGAPORE_RECEIVER]
- 2020-02-05 09:18:28.689 ERROR 12305 --- [ask-scheduler-2] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to obtain partition information
- org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [SINGAPORE_RECEIVER]
- 2020-02-05 09:18:28.689 INFO 12305 --- [ask-scheduler-2] o.a.k.clients.admin.AdminClientConfig : AdminClientConfig values:
- bootstrap.servers = [localhost:9090]
- client.dns.lookup = default
- client.id =
- connections.max.idle.ms = 300000
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- receive.buffer.bytes = 65536
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 120000
- retries = 5
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = [hidden]
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = SCRAM-SHA-512
- security.protocol = SASL_SSL
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- 2020-02-05 09:18:28.693 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.3.1
- 2020-02-05 09:18:28.693 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 18a913733fb71c01
- 2020-02-05 09:18:28.693 INFO 12305 --- [ask-scheduler-2] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1580869108693
- 2020-02-05 09:18:28.912 WARN 12305 --- [ask-scheduler-2] o.s.c.s.b.k.p.KafkaTopicProvisioner : No partitions have been retrieved for the topic (SINGAPORE_RECEIVER). This will affect the health check.
- 2020-02-05 09:18:28.913 ERROR 12305 --- [ask-scheduler-2] o.s.c.s.b.k.p.KafkaTopicProvisioner : Cannot initialize Binder
- java.lang.IllegalStateException: The number of expected partitions was: 1, but 0 has been found instead
- at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.lambda$getPartitionsForTopic$2(KafkaTopicProvisioner.java:502) ~[spring-cloud-stream-binder-kafka-core-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:287) ~[spring-retry-1.2.5.RELEASE.jar:na]
- at org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:164) ~[spring-retry-1.2.5.RELEASE.jar:na]
- at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.getPartitionsForTopic(KafkaTopicProvisioner.java:453) ~[spring-cloud-stream-binder-kafka-core-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.createProducerMessageHandler(KafkaMessageChannelBinder.java:349) ~[spring-cloud-stream-binder-kafka-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.createProducerMessageHandler(KafkaMessageChannelBinder.java:147) ~[spring-cloud-stream-binder-kafka-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:225) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:90) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.cloud.stream.binder.AbstractBinder.bindProducer(AbstractBinder.java:152) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.cloud.stream.binding.BindingService.lambda$rescheduleProducerBinding$2(BindingService.java:319) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
- at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[na:na]
- at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[na:na]
- at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) ~[na:na]
- at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[na:na]
- at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[na:na]
- at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]
- 2020-02-05 09:18:28.914 ERROR 12305 --- [ask-scheduler-2] o.s.cloud.stream.binding.BindingService : Failed to create producer binding; retrying in 30 seconds
- org.springframework.cloud.stream.binder.BinderException: Cannot initialize binder:
- at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.getPartitionsForTopic(KafkaTopicProvisioner.java:514) ~[spring-cloud-stream-binder-kafka-core-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.createProducerMessageHandler(KafkaMessageChannelBinder.java:349) ~[spring-cloud-stream-binder-kafka-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.createProducerMessageHandler(KafkaMessageChannelBinder.java:147) ~[spring-cloud-stream-binder-kafka-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:225) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:90) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.cloud.stream.binder.AbstractBinder.bindProducer(AbstractBinder.java:152) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.cloud.stream.binding.BindingService.lambda$rescheduleProducerBinding$2(BindingService.java:319) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
- at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[na:na]
- at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[na:na]
- at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) ~[na:na]
- at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[na:na]
- at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[na:na]
- at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]
- Caused by: java.lang.IllegalStateException: The number of expected partitions was: 1, but 0 has been found instead
- at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.lambda$getPartitionsForTopic$2(KafkaTopicProvisioner.java:502) ~[spring-cloud-stream-binder-kafka-core-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:287) ~[spring-retry-1.2.5.RELEASE.jar:na]
- at org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:164) ~[spring-retry-1.2.5.RELEASE.jar:na]
- at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.getPartitionsForTopic(KafkaTopicProvisioner.java:453) ~[spring-cloud-stream-binder-kafka-core-3.0.1.RELEASE.jar:3.0.1.RELEASE]
- ... 13 common frames omitted
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement