API tools faq
paste
Advertisement
yetaji7426

Untitled

yetaji7426
Feb 4th, 2020
395
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 35.79 KB | None | 0 0
raw download clone embed print report
  1. Here is my configuration:
  2. spring:
  3. cloud:
  4. stream:
  5. default-binder: kafka
  6. bindings:
  7. SINGAPOR_RECEIVER:
  8. binder: kafka
  9. destination: SINGAPOR_RECEIVER
  10. group: group-1
  11. content-type: text/plain
  12. SINGAPOR_RESPOND:
  13. binder: kafka
  14. destination: SINGAPOR_RESPOND
  15. group: group-1
  16. content-type: text/plain
  17. RESULT_RESPOND:
  18. binder: kafka
  19. destination: RESULT_RESPOND
  20. group: group-1
  21. content-type: text/plain
  22.  
  23.  
  24.  
  25. spring.kafka.bootstrap-servers: localhost:9090
  26. spring.kafka.properties.security.protocol: SASL_SSL
  27. spring.kafka.properties.sasl.mechanism: SCRAM-SHA-512
  28. spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.scram.ScramLoginModule required username="userkk" password="admin-secret";
  29.  
  30.  
  31.  
  32. Here is the way I set ACL and its output:
  33. $KAFKA/bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --add --allow-principal User:userkk --allow-host 127.0.0.1 --allow-host localhost --operation Read --operation Write --operation ALL --topic test --topic SINGAPOR_RESPOND --topic SINGAPOR_RECEIVER --topic RESULT_RESPOND --topic * –group group-1
  34.  
  35. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=RESULT_RESPOND, patternType=LITERAL)`:
  36. (principal=User:userkk, host=127.0.0.1, operation=READ, permissionType=ALLOW)
  37. (principal=User:userkk, host=localhost, operation=WRITE, permissionType=ALLOW)
  38. (principal=User:userkk, host=localhost, operation=READ, permissionType=ALLOW)
  39. (principal=User:userkk, host=127.0.0.1, operation=ALL, permissionType=ALLOW)
  40. (principal=User:userkk, host=localhost, operation=ALL, permissionType=ALLOW)
  41. (principal=User:userkk, host=127.0.0.1, operation=WRITE, permissionType=ALLOW)
  42.  
  43. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=test, patternType=LITERAL)`:
  44. (principal=User:userkk, host=127.0.0.1, operation=READ, permissionType=ALLOW)
  45. (principal=User:userkk, host=localhost, operation=WRITE, permissionType=ALLOW)
  46. (principal=User:userkk, host=localhost, operation=READ, permissionType=ALLOW)
  47. (principal=User:userkk, host=127.0.0.1, operation=ALL, permissionType=ALLOW)
  48. (principal=User:userkk, host=localhost, operation=ALL, permissionType=ALLOW)
  49. (principal=User:userkk, host=127.0.0.1, operation=WRITE, permissionType=ALLOW)
  50.  
  51. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=SINGAPOR_RESPOND, patternType=LITERAL)`:
  52. (principal=User:userkk, host=127.0.0.1, operation=READ, permissionType=ALLOW)
  53. (principal=User:userkk, host=localhost, operation=WRITE, permissionType=ALLOW)
  54. (principal=User:userkk, host=localhost, operation=READ, permissionType=ALLOW)
  55. (principal=User:userkk, host=127.0.0.1, operation=ALL, permissionType=ALLOW)
  56. (principal=User:userkk, host=localhost, operation=ALL, permissionType=ALLOW)
  57. (principal=User:userkk, host=127.0.0.1, operation=WRITE, permissionType=ALLOW)
  58.  
  59. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=build, patternType=LITERAL)`:
  60. (principal=User:userkk, host=127.0.0.1, operation=READ, permissionType=ALLOW)
  61. (principal=User:userkk, host=localhost, operation=WRITE, permissionType=ALLOW)
  62. (principal=User:userkk, host=localhost, operation=READ, permissionType=ALLOW)
  63. (principal=User:userkk, host=127.0.0.1, operation=ALL, permissionType=ALLOW)
  64. (principal=User:userkk, host=localhost, operation=ALL, permissionType=ALLOW)
  65. (principal=User:userkk, host=127.0.0.1, operation=WRITE, permissionType=ALLOW)
  66.  
  67. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=SINGAPOR_RECEIVER, patternType=LITERAL)`:
  68. (principal=User:userkk, host=127.0.0.1, operation=READ, permissionType=ALLOW)
  69. (principal=User:userkk, host=localhost, operation=WRITE, permissionType=ALLOW)
  70. (principal=User:userkk, host=localhost, operation=READ, permissionType=ALLOW)
  71. (principal=User:userkk, host=127.0.0.1, operation=ALL, permissionType=ALLOW)
  72. (principal=User:userkk, host=localhost, operation=ALL, permissionType=ALLOW)
  73. (principal=User:userkk, host=127.0.0.1, operation=WRITE, permissionType=ALLOW)
  74.  
  75. Current ACLs for resource `Topic:LITERAL:RESULT_RESPOND`:
  76. User:userkk has Allow permission for operations: All from hosts: localhost
  77. User:userkk has Allow permission for operations: Read from hosts: 127.0.0.1
  78. User:userkk has Allow permission for operations: All from hosts: 127.0.0.1
  79. User:userkk has Allow permission for operations: Write from hosts: localhost
  80. User:userkk has Allow permission for operations: Write from hosts: 127.0.0.1
  81. User:userkk has Allow permission for operations: Read from hosts: localhost
  82.  
  83. Current ACLs for resource `Topic:LITERAL:SINGAPOR_RECEIVER`:
  84. User:userkk has Allow permission for operations: All from hosts: localhost
  85. User:userkk has Allow permission for operations: Read from hosts: 127.0.0.1
  86. User:userkk has Allow permission for operations: All from hosts: 127.0.0.1
  87. User:userkk has Allow permission for operations: Write from hosts: localhost
  88. User:userkk has Allow permission for operations: Write from hosts: 127.0.0.1
  89. User:userkk has Allow permission for operations: Read from hosts: localhost
  90.  
  91. Current ACLs for resource `Topic:LITERAL:build`:
  92. User:userkk has Allow permission for operations: All from hosts: localhost
  93. User:userkk has Allow permission for operations: Read from hosts: 127.0.0.1
  94. User:userkk has Allow permission for operations: All from hosts: 127.0.0.1
  95. User:userkk has Allow permission for operations: Write from hosts: localhost
  96. User:userkk has Allow permission for operations: Write from hosts: 127.0.0.1
  97. User:userkk has Allow permission for operations: Read from hosts: localhost
  98.  
  99. Current ACLs for resource `Topic:LITERAL:SINGAPOR_RESPOND`:
  100. User:userkk has Allow permission for operations: All from hosts: localhost
  101. User:userkk has Allow permission for operations: Read from hosts: 127.0.0.1
  102. User:userkk has Allow permission for operations: All from hosts: 127.0.0.1
  103. User:userkk has Allow permission for operations: Write from hosts: localhost
  104. User:userkk has Allow permission for operations: Write from hosts: 127.0.0.1
  105. User:userkk has Allow permission for operations: Read from hosts: localhost
  106.  
  107. Current ACLs for resource `Topic:LITERAL:test`:
  108. User:userkk has Allow permission for operations: All from hosts: localhost
  109. User:userkk has Allow permission for operations: Read from hosts: 127.0.0.1
  110. User:userkk has Allow permission for operations: All from hosts: 127.0.0.1
  111. User:userkk has Allow permission for operations: Write from hosts: localhost
  112. User:userkk has Allow permission for operations: Write from hosts: 127.0.0.1
  113. User:userkk has Allow permission for operations: Read from hosts: localhost
  114.  
  115.  
  116.  
  117. And here is the log i got from Spring boot console:
  118. 2020-02-05 08:50:45.063 INFO 8275 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat initialized with port(s): 9088 (http)
  119. 2020-02-05 08:50:45.076 INFO 8275 --- [ main] o.apache.catalina.core.StandardService : Starting service [Tomcat]
  120. 2020-02-05 08:50:45.076 INFO 8275 --- [ main] org.apache.catalina.core.StandardEngine : Starting Servlet engine: [Apache Tomcat/9.0.30]
  121. 2020-02-05 08:50:45.145 INFO 8275 --- [ main] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded WebApplicationContext
  122. 2020-02-05 08:50:45.145 INFO 8275 --- [ main] o.s.web.context.ContextLoader : Root WebApplicationContext: initialization completed in 1325 ms
  123. 2020-02-05 08:50:45.493 INFO 8275 --- [ main] o.s.s.concurrent.ThreadPoolTaskExecutor : Initializing ExecutorService 'applicationTaskExecutor'
  124. 2020-02-05 08:50:45.727 INFO 8275 --- [ main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 'taskScheduler'
  125. 2020-02-05 08:50:45.865 INFO 8275 --- [ main] o.s.c.s.m.DirectWithAttributesChannel : Channel 'application.SINGAPORE_RESPOND' has 1 subscriber(s).
  126. 2020-02-05 08:50:45.871 INFO 8275 --- [ main] o.s.i.endpoint.EventDrivenConsumer : Adding {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel
  127. 2020-02-05 08:50:45.871 INFO 8275 --- [ main] o.s.i.channel.PublishSubscribeChannel : Channel 'application.errorChannel' has 1 subscriber(s).
  128. 2020-02-05 08:50:45.871 INFO 8275 --- [ main] o.s.i.endpoint.EventDrivenConsumer : started bean '_org.springframework.integration.errorLogger'
  129. 2020-02-05 08:50:46.050 INFO 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Using kafka topic for outbound: SINGAPORE_RECEIVER
  130. 2020-02-05 08:50:46.052 INFO 8275 --- [ main] o.a.k.clients.admin.AdminClientConfig : AdminClientConfig values:
  131. bootstrap.servers = [SASL_SSL://localhost:9090]
  132. client.dns.lookup = default
  133. client.id =
  134. connections.max.idle.ms = 300000
  135. metadata.max.age.ms = 300000
  136. metric.reporters = []
  137. metrics.num.samples = 2
  138. metrics.recording.level = INFO
  139. metrics.sample.window.ms = 30000
  140. receive.buffer.bytes = 65536
  141. reconnect.backoff.max.ms = 1000
  142. reconnect.backoff.ms = 50
  143. request.timeout.ms = 120000
  144. retries = 5
  145. retry.backoff.ms = 100
  146. sasl.client.callback.handler.class = null
  147. sasl.jaas.config = [hidden]
  148. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  149. sasl.kerberos.min.time.before.relogin = 60000
  150. sasl.kerberos.service.name = null
  151. sasl.kerberos.ticket.renew.jitter = 0.05
  152. sasl.kerberos.ticket.renew.window.factor = 0.8
  153. sasl.login.callback.handler.class = null
  154. sasl.login.class = null
  155. sasl.login.refresh.buffer.seconds = 300
  156. sasl.login.refresh.min.period.seconds = 60
  157. sasl.login.refresh.window.factor = 0.8
  158. sasl.login.refresh.window.jitter = 0.05
  159. sasl.mechanism = SCRAM-SHA-512
  160. security.protocol = SASL_SSL
  161. send.buffer.bytes = 131072
  162. ssl.cipher.suites = null
  163. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  164. ssl.endpoint.identification.algorithm = https
  165. ssl.key.password = null
  166. ssl.keymanager.algorithm = SunX509
  167. ssl.keystore.location = null
  168. ssl.keystore.password = null
  169. ssl.keystore.type = JKS
  170. ssl.protocol = TLS
  171. ssl.provider = null
  172. ssl.secure.random.implementation = null
  173. ssl.trustmanager.algorithm = PKIX
  174. ssl.truststore.location = null
  175. ssl.truststore.password = null
  176. ssl.truststore.type = JKS
  177.  
  178. 2020-02-05 08:50:46.198 INFO 8275 --- [ main] o.a.k.c.s.authenticator.AbstractLogin : Successfully logged in.
  179. 2020-02-05 08:50:46.332 INFO 8275 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.3.1
  180. 2020-02-05 08:50:46.333 INFO 8275 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 18a913733fb71c01
  181. 2020-02-05 08:50:46.333 INFO 8275 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1580867446331
  182. 2020-02-05 08:50:46.810 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  183.  
  184. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  185.  
  186. 2020-02-05 08:50:46.915 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  187.  
  188. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  189.  
  190. 2020-02-05 08:50:47.127 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  191.  
  192. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  193.  
  194. 2020-02-05 08:50:47.534 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  195.  
  196. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  197.  
  198. 2020-02-05 08:50:48.342 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  199.  
  200. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  201.  
  202. 2020-02-05 08:50:49.352 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  203.  
  204. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  205.  
  206. 2020-02-05 08:50:50.360 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  207.  
  208. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  209.  
  210. 2020-02-05 08:50:51.369 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  211.  
  212. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  213.  
  214. 2020-02-05 08:50:52.376 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  215.  
  216. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  217.  
  218. 2020-02-05 08:50:53.384 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  219.  
  220. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  221.  
  222. 2020-02-05 08:50:53.407 ERROR 8275 --- [ main] o.s.cloud.stream.binding.BindingService : Failed to create producer binding; retrying in 30 seconds
  223.  
  224. org.springframework.cloud.stream.provisioning.ProvisioningException: Provisioning exception; nested exception is org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  225. at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.createTopic(KafkaTopicProvisioner.java:319) ~[spring-cloud-stream-binder-kafka-core-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  226. at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionProducerDestination(KafkaTopicProvisioner.java:141) ~[spring-cloud-stream-binder-kafka-core-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  227. at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionProducerDestination(KafkaTopicProvisioner.java:78) ~[spring-cloud-stream-binder-kafka-core-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  228. at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:222) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  229. at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:90) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  230. at org.springframework.cloud.stream.binder.AbstractBinder.bindProducer(AbstractBinder.java:152) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  231. at org.springframework.cloud.stream.binding.BindingService.doBindProducer(BindingService.java:296) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  232. at org.springframework.cloud.stream.binding.BindingService.bindProducer(BindingService.java:271) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  233. at org.springframework.cloud.stream.binding.AbstractBindableProxyFactory.createAndBindOutputs(AbstractBindableProxyFactory.java:136) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  234. at org.springframework.cloud.stream.binding.OutputBindingLifecycle.doStartWithBindable(OutputBindingLifecycle.java:58) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  235. at java.base/java.util.LinkedHashMap$LinkedValues.forEach(LinkedHashMap.java:608) ~[na:na]
  236. at org.springframework.cloud.stream.binding.AbstractBindingLifecycle.start(AbstractBindingLifecycle.java:57) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  237. at org.springframework.cloud.stream.binding.OutputBindingLifecycle.start(OutputBindingLifecycle.java:34) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  238. at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:182) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  239. at org.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:53) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  240. at org.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:360) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  241. at org.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:158) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  242. at org.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:122) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  243. at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:894) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  244. at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.finishRefresh(ServletWebServerApplicationContext.java:162) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  245. at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:553) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  246. at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:141) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  247. at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:747) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  248. at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  249. at org.springframework.boot.SpringApplication.run(SpringApplication.java:315) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  250. at org.springframework.boot.SpringApplication.run(SpringApplication.java:1226) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  251. at org.springframework.boot.SpringApplication.run(SpringApplication.java:1215) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  252. at com.gdce.doca.ApplicationKt.main(Application.kt:17) ~[main/:na]
  253. Caused by: org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  254.  
  255. 2020-02-05 08:50:53.415 INFO 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Using kafka topic for outbound: RESULT_RESPOND
  256. 2020-02-05 08:50:53.417 INFO 8275 --- [ main] o.a.k.clients.admin.AdminClientConfig : AdminClientConfig values:
  257. bootstrap.servers = [SASL_SSL://localhost:9090]
  258. client.dns.lookup = default
  259. client.id =
  260. connections.max.idle.ms = 300000
  261. metadata.max.age.ms = 300000
  262. metric.reporters = []
  263. metrics.num.samples = 2
  264. metrics.recording.level = INFO
  265. metrics.sample.window.ms = 30000
  266. receive.buffer.bytes = 65536
  267. reconnect.backoff.max.ms = 1000
  268. reconnect.backoff.ms = 50
  269. request.timeout.ms = 120000
  270. retries = 5
  271. retry.backoff.ms = 100
  272. sasl.client.callback.handler.class = null
  273. sasl.jaas.config = [hidden]
  274. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  275. sasl.kerberos.min.time.before.relogin = 60000
  276. sasl.kerberos.service.name = null
  277. sasl.kerberos.ticket.renew.jitter = 0.05
  278. sasl.kerberos.ticket.renew.window.factor = 0.8
  279. sasl.login.callback.handler.class = null
  280. sasl.login.class = null
  281. sasl.login.refresh.buffer.seconds = 300
  282. sasl.login.refresh.min.period.seconds = 60
  283. sasl.login.refresh.window.factor = 0.8
  284. sasl.login.refresh.window.jitter = 0.05
  285. sasl.mechanism = SCRAM-SHA-512
  286. security.protocol = SASL_SSL
  287. send.buffer.bytes = 131072
  288. ssl.cipher.suites = null
  289. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  290. ssl.endpoint.identification.algorithm = https
  291. ssl.key.password = null
  292. ssl.keymanager.algorithm = SunX509
  293. ssl.keystore.location = null
  294. ssl.keystore.password = null
  295. ssl.keystore.type = JKS
  296. ssl.protocol = TLS
  297. ssl.provider = null
  298. ssl.secure.random.implementation = null
  299. ssl.trustmanager.algorithm = PKIX
  300. ssl.truststore.location = null
  301. ssl.truststore.password = null
  302. ssl.truststore.type = JKS
  303.  
  304. 2020-02-05 08:50:53.420 INFO 8275 --- [ main] o.a.k.c.s.authenticator.AbstractLogin : Successfully logged in.
  305. 2020-02-05 08:50:53.432 INFO 8275 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.3.1
  306. 2020-02-05 08:50:53.433 INFO 8275 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 18a913733fb71c01
  307. 2020-02-05 08:50:53.433 INFO 8275 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1580867453432
  308. 2020-02-05 08:50:53.722 INFO 8275 --- [ main] o.a.k.clients.producer.ProducerConfig : ProducerConfig values:
  309. acks = 1
  310. batch.size = 16384
  311. bootstrap.servers = [SASL_SSL://localhost:9090]
  312. buffer.memory = 33554432
  313. client.dns.lookup = default
  314. client.id =
  315. compression.type = none
  316. connections.max.idle.ms = 540000
  317. delivery.timeout.ms = 120000
  318. enable.idempotence = false
  319. interceptor.classes = []
  320. key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  321. linger.ms = 0
  322. max.block.ms = 60000
  323. max.in.flight.requests.per.connection = 5
  324. max.request.size = 1048576
  325. metadata.max.age.ms = 300000
  326. metric.reporters = []
  327. metrics.num.samples = 2
  328. metrics.recording.level = INFO
  329. metrics.sample.window.ms = 30000
  330. partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
  331. receive.buffer.bytes = 32768
  332. reconnect.backoff.max.ms = 1000
  333. reconnect.backoff.ms = 50
  334. request.timeout.ms = 30000
  335. retries = 0
  336. retry.backoff.ms = 100
  337. sasl.client.callback.handler.class = null
  338. sasl.jaas.config = [hidden]
  339. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  340. sasl.kerberos.min.time.before.relogin = 60000
  341. sasl.kerberos.service.name = null
  342. sasl.kerberos.ticket.renew.jitter = 0.05
  343. sasl.kerberos.ticket.renew.window.factor = 0.8
  344. sasl.login.callback.handler.class = null
  345. sasl.login.class = null
  346. sasl.login.refresh.buffer.seconds = 300
  347. sasl.login.refresh.min.period.seconds = 60
  348. sasl.login.refresh.window.factor = 0.8
  349. sasl.login.refresh.window.jitter = 0.05
  350. sasl.mechanism = SCRAM-SHA-512
  351. security.protocol = SASL_SSL
  352. send.buffer.bytes = 131072
  353. ssl.cipher.suites = null
  354. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  355. ssl.endpoint.identification.algorithm = https
  356. ssl.key.password = null
  357. ssl.keymanager.algorithm = SunX509
  358. ssl.keystore.location = null
  359. ssl.keystore.password = null
  360. ssl.keystore.type = JKS
  361. ssl.protocol = TLS
  362. ssl.provider = null
  363. ssl.secure.random.implementation = null
  364. ssl.trustmanager.algorithm = PKIX
  365. ssl.truststore.location = null
  366. ssl.truststore.password = null
  367. ssl.truststore.type = JKS
  368. transaction.timeout.ms = 60000
  369. transactional.id = null
  370. value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  371.  
  372. 2020-02-05 08:50:53.738 INFO 8275 --- [ main] o.a.k.c.s.authenticator.AbstractLogin : Successfully logged in.
  373. 2020-02-05 08:50:53.751 INFO 8275 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.3.1
  374. 2020-02-05 08:50:53.751 INFO 8275 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 18a913733fb71c01
  375. 2020-02-05 08:50:53.751 INFO 8275 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1580867453751
  376. 2020-02-05 08:50:53.844 INFO 8275 --- [ad | producer-1] org.apache.kafka.clients.Metadata : [Producer clientId=producer-1] Cluster ID: TUJs_pIKRNi4QU17gTTaiw
  377. 2020-02-05 08:50:53.848 INFO 8275 --- [ main] o.a.k.clients.producer.KafkaProducer : [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 30000 ms.
  378. 2020-02-05 08:50:53.869 INFO 8275 --- [ main] o.s.c.s.m.DirectWithAttributesChannel : Channel 'application.RESULT_RESPOND' has 1 subscriber(s).
  379. 2020-02-05 08:50:53.889 INFO 8275 --- [ main] o.a.k.clients.admin.AdminClientConfig : AdminClientConfig values:
  380. bootstrap.servers = [SASL_SSL://localhost:9090]
  381. client.dns.lookup = default
  382. client.id =
  383. connections.max.idle.ms = 300000
  384. metadata.max.age.ms = 300000
  385. metric.reporters = []
  386. metrics.num.samples = 2
  387. metrics.recording.level = INFO
  388. metrics.sample.window.ms = 30000
  389. receive.buffer.bytes = 65536
  390. reconnect.backoff.max.ms = 1000
  391. reconnect.backoff.ms = 50
  392. request.timeout.ms = 120000
  393. retries = 5
  394. retry.backoff.ms = 100
  395. sasl.client.callback.handler.class = null
  396. sasl.jaas.config = [hidden]
  397. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  398. sasl.kerberos.min.time.before.relogin = 60000
  399. sasl.kerberos.service.name = null
  400. sasl.kerberos.ticket.renew.jitter = 0.05
  401. sasl.kerberos.ticket.renew.window.factor = 0.8
  402. sasl.login.callback.handler.class = null
  403. sasl.login.class = null
  404. sasl.login.refresh.buffer.seconds = 300
  405. sasl.login.refresh.min.period.seconds = 60
  406. sasl.login.refresh.window.factor = 0.8
  407. sasl.login.refresh.window.jitter = 0.05
  408. sasl.mechanism = SCRAM-SHA-512
  409. security.protocol = SASL_SSL
  410. send.buffer.bytes = 131072
  411. ssl.cipher.suites = null
  412. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  413. ssl.endpoint.identification.algorithm = https
  414. ssl.key.password = null
  415. ssl.keymanager.algorithm = SunX509
  416. ssl.keystore.location = null
  417. ssl.keystore.password = null
  418. ssl.keystore.type = JKS
  419. ssl.protocol = TLS
  420. ssl.provider = null
  421. ssl.secure.random.implementation = null
  422. ssl.trustmanager.algorithm = PKIX
  423. ssl.truststore.location = null
  424. ssl.truststore.password = null
  425. ssl.truststore.type = JKS
  426.  
  427. 2020-02-05 08:50:53.890 INFO 8275 --- [ main] o.a.k.c.s.authenticator.AbstractLogin : Successfully logged in.
  428. 2020-02-05 08:50:53.892 INFO 8275 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.3.1
  429. 2020-02-05 08:50:53.892 INFO 8275 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 18a913733fb71c01
  430. 2020-02-05 08:50:53.893 INFO 8275 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1580867453892
  431. 2020-02-05 08:50:54.083 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  432.  
  433. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  434.  
  435. 2020-02-05 08:50:54.187 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  436.  
  437. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  438.  
  439. 2020-02-05 08:50:54.392 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  440.  
  441. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  442.  
  443. 2020-02-05 08:50:54.800 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  444.  
  445. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  446.  
  447. 2020-02-05 08:50:55.608 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  448.  
  449. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  450.  
  451. 2020-02-05 08:50:56.613 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  452.  
  453. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  454.  
  455. 2020-02-05 08:50:57.620 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  456.  
  457. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  458.  
  459. 2020-02-05 08:50:58.627 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  460.  
  461. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  462.  
  463. 2020-02-05 08:50:59.633 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  464.  
  465. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  466.  
  467. 2020-02-05 08:51:00.643 ERROR 8275 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Failed to create topics
  468.  
  469. org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  470.  
  471. 2020-02-05 08:51:00.649 ERROR 8275 --- [ main] o.s.cloud.stream.binding.BindingService : Failed to create consumer binding; retrying in 30 seconds
  472.  
  473. org.springframework.cloud.stream.provisioning.ProvisioningException: Provisioning exception; nested exception is org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  474. at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.createTopic(KafkaTopicProvisioner.java:319) ~[spring-cloud-stream-binder-kafka-core-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  475. at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.doProvisionConsumerDestination(KafkaTopicProvisioner.java:204) ~[spring-cloud-stream-binder-kafka-core-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  476. at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionConsumerDestination(KafkaTopicProvisioner.java:170) ~[spring-cloud-stream-binder-kafka-core-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  477. at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionConsumerDestination(KafkaTopicProvisioner.java:78) ~[spring-cloud-stream-binder-kafka-core-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  478. at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindConsumer(AbstractMessageChannelBinder.java:408) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  479. at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindConsumer(AbstractMessageChannelBinder.java:90) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  480. at org.springframework.cloud.stream.binder.AbstractBinder.bindConsumer(AbstractBinder.java:143) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  481. at org.springframework.cloud.stream.binding.BindingService.doBindConsumer(BindingService.java:169) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  482. at org.springframework.cloud.stream.binding.BindingService.bindConsumer(BindingService.java:126) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  483. at org.springframework.cloud.stream.binding.AbstractBindableProxyFactory.createAndBindInputs(AbstractBindableProxyFactory.java:112) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  484. at org.springframework.cloud.stream.binding.InputBindingLifecycle.doStartWithBindable(InputBindingLifecycle.java:58) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  485. at java.base/java.util.LinkedHashMap$LinkedValues.forEach(LinkedHashMap.java:608) ~[na:na]
  486. at org.springframework.cloud.stream.binding.AbstractBindingLifecycle.start(AbstractBindingLifecycle.java:57) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  487. at org.springframework.cloud.stream.binding.InputBindingLifecycle.start(InputBindingLifecycle.java:34) ~[spring-cloud-stream-3.0.1.RELEASE.jar:3.0.1.RELEASE]
  488. at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:182) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  489. at org.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:53) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  490. at org.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:360) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  491. at org.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:158) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  492. at org.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:122) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  493. at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:894) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  494. at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.finishRefresh(ServletWebServerApplicationContext.java:162) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  495. at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:553) ~[spring-context-5.2.3.RELEASE.jar:5.2.3.RELEASE]
  496. at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:141) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  497. at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:747) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  498. at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  499. at org.springframework.boot.SpringApplication.run(SpringApplication.java:315) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  500. at org.springframework.boot.SpringApplication.run(SpringApplication.java:1226) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  501. at org.springframework.boot.SpringApplication.run(SpringApplication.java:1215) ~[spring-boot-2.2.4.RELEASE.jar:2.2.4.RELEASE]
  502. at com.gdce.doca.ApplicationKt.main(Application.kt:17) ~[main/:na]
  503. Caused by: org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Authorization failed.]
  504.  
  505. 2020-02-05 08:51:00.707 INFO 8275 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 9088 (http) with context path ''
  506. 2020-02-05 08:51:00.709 INFO 8275 --- [ main] com.gdce.doca.ApplicationKt : Started ApplicationKt in 17.569 seconds (JVM running for 18.024)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!