API tools faq
paste
alexpetro000

Untitled

alexpetro000
Jul 16th, 2020
380
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 8.86 KB | None | 0 0
raw download clone embed print report
  1. kafka-connect-initializer_1 | elasticsearch-catalog-items configuration to be applied:
  2. kafka-connect-initializer_1 | {
  3. kafka-connect-initializer_1 | "connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
  4. kafka-connect-initializer_1 | "tasks.max": "1",
  5. kafka-connect-initializer_1 |
  6. kafka-connect-initializer_1 | "auto.create.indices.at.start": "false",
  7. kafka-connect-initializer_1 | "topics": "srv_v1_edu.service.core.search_item.registry_createOrUpdate",
  8. kafka-connect-initializer_1 | "transforms": "routeToIndex",
  9. kafka-connect-initializer_1 | "transforms.routeToIndex.type": "org.apache.kafka.connect.transforms.RegexRouter",
  10. kafka-connect-initializer_1 | "transforms.routeToIndex.regex": ".*",
  11. kafka-connect-initializer_1 | "transforms.routeToIndex.replacement": "catalog_item_registry_write",
  12. kafka-connect-initializer_1 |
  13. kafka-connect-initializer_1 | "schema.ignore": "true",
  14. kafka-connect-initializer_1 | "key.converter": "org.apache.kafka.connect.storage.StringConverter",
  15. kafka-connect-initializer_1 | "key.converter.schemas.enable": "false",
  16. kafka-connect-initializer_1 | "value.converter": "org.apache.kafka.connect.json.JsonConverter",
  17. kafka-connect-initializer_1 | "value.converter.schemas.enable": "false",
  18. kafka-connect-initializer_1 | "connection.url": "http://elasticsearch:9200",
  19. kafka-connect-initializer_1 | "connection.username": "%ES_USERNAME%",
  20. kafka-connect-initializer_1 | "connection.password": "%ES_PASSWORD%",
  21. kafka-connect-initializer_1 | "behavior.on.null.values": "delete",
  22. kafka-connect-initializer_1 | "type.name": "_doc",
  23. kafka-connect-initializer_1 |
  24. kafka-connect-initializer_1 | "errors.tolerance": "all",
  25. kafka-connect-initializer_1 | "errors.log.enable": true,
  26. kafka-connect-initializer_1 | "errors.log.include.messages": true,
  27. kafka-connect-initializer_1 | "errors.deadletterqueue.topic.replication.factor": "1",
  28. kafka-connect-initializer_1 | "errors.deadletterqueue.topic.name": "srv_v1_edu.service.core.search_item.registry_dlq",
  29. kafka-connect-initializer_1 | "errors.deadletterqueue.context.headers.enable": true
  30. kafka-connect-initializer_1 | }
  31. kafka-connect-initializer_1 | % Total % Received % Xferd Average Speed Time Time Time Current
  32. kafka-connect-initializer_1 | Dload Upload Total Spent Left Speed
  33. 0 0 0 0 0 0 0 0 --:--:-- --:--:-- --:--:-- 0* Trying 172.19.0.14:8083...
  34. kafka-connect-initializer_1 | * Connected to kafka-connect (172.19.0.14) port 8083 (#0)
  35. kafka-connect-initializer_1 | > PUT /connectors/elasticsearch-catalog-items/config HTTP/1.1
  36. kafka-connect-initializer_1 | > Host: kafka-connect:8083
  37. kafka-connect-initializer_1 | > User-Agent: curl/7.69.1-DEV
  38. kafka-connect-initializer_1 | > Accept: */*
  39. kafka-connect-initializer_1 | > Content-Type: application/json
  40. kafka-connect-initializer_1 | > Content-Length: 1157
  41. kafka-connect-initializer_1 | >
  42. kafka-connect-initializer_1 | } [1157 bytes data]
  43. kafka-connect-initializer_1 | * upload completely sent off: 1157 out of 1157 bytes
  44. 100 1157 0 0 100 1157 0 5509 --:--:-- --:--:-- --:--:-- 5483* Mark bundle as not supporting multiuse
  45. kafka-connect-initializer_1 | < HTTP/1.1 201 Created
  46. kafka-connect-initializer_1 | < Date: Thu, 16 Jul 2020 09:20:32 GMT
  47. kafka-connect-initializer_1 | < Location: http://kafka-connect:8083/connectors/elasticsearch-catalog-items
  48. kafka-connect-initializer_1 | < Content-Type: application/json
  49. kafka-connect-initializer_1 | < Content-Length: 1201
  50. kafka-connect-initializer_1 | < Server: Jetty(9.4.24.v20191120)
  51. kafka-connect-initializer_1 | <
  52. kafka-connect-initializer_1 | { [1201 bytes data]
  53. 100 2358 100 1201 100 1157 1828 1761 --:--:-- --:--:-- --:--:-- 3583
  54. kafka-connect-initializer_1 | * Connection #0 to host kafka-connect left intact
  55. kafka-connect-initializer_1 | Creating connector elasticsearch-catalog-items ... done
  56. kafka-connect-initializer_1 | elasticsearch-external-tasks configuration to be applied:
  57. kafka-connect-initializer_1 | {
  58. kafka-connect-initializer_1 | "connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
  59. kafka-connect-initializer_1 | "tasks.max": "1",
  60. kafka-connect-initializer_1 |
  61. kafka-connect-initializer_1 | "auto.create.indices.at.start": "false",
  62. kafka-connect-initializer_1 | "topics": "srv_v1_edu.service.core.search_content.external_task_createOrUpdate",
  63. kafka-connect-initializer_1 | "transforms": "routeToIndex",
  64. kafka-connect-initializer_1 | "transforms.routeToIndex.type": "org.apache.kafka.connect.transforms.RegexRouter",
  65. kafka-connect-initializer_1 | "transforms.routeToIndex.regex": ".*",
  66. kafka-connect-initializer_1 | "transforms.routeToIndex.replacement": "external_task_write",
  67. kafka-connect-initializer_1 |
  68. kafka-connect-initializer_1 | "schema.ignore": "true",
  69. kafka-connect-initializer_1 | "key.converter": "org.apache.kafka.connect.storage.StringConverter",
  70. kafka-connect-initializer_1 | "key.converter.schemas.enable": "false",
  71. kafka-connect-initializer_1 | "value.converter": "org.apache.kafka.connect.json.JsonConverter",
  72. kafka-connect-initializer_1 | "value.converter.schemas.enable": "false",
  73. kafka-connect-initializer_1 | "connection.url": "http://elasticsearch:9200",
  74. kafka-connect-initializer_1 | "connection.username": "%ES_USERNAME%",
  75. kafka-connect-initializer_1 | "connection.password": "%ES_PASSWORD%",
  76. kafka-connect-initializer_1 | "behavior.on.null.values": "delete",
  77. kafka-connect-initializer_1 | "type.name": "_doc",
  78. kafka-connect-initializer_1 |
  79. kafka-connect-initializer_1 | "errors.tolerance": "all",
  80. kafka-connect-initializer_1 | "errors.log.enable": true,
  81. kafka-connect-initializer_1 | "errors.log.include.messages": true,
  82. kafka-connect-initializer_1 | "errors.deadletterqueue.topic.replication.factor": "1",
  83. kafka-connect-initializer_1 | "errors.deadletterqueue.topic.name": "srv_v1_edu.service.core.search_content.external_task_dlq",
  84. kafka-connect-initializer_1 | "errors.deadletterqueue.context.headers.enable": true
  85. kafka-connect-initializer_1 | }
  86. kafka-connect-initializer_1 | % Total % Received % Xferd Average Speed Time Time Time Current
  87. kafka-connect-initializer_1 | Dload Upload Total Spent Left Speed
  88. 0 0 0 0 0 0 0 0 --:--:-- --:--:-- --:--:-- 0* Trying 172.19.0.14:8083...
  89. kafka-connect-initializer_1 | * Connected to kafka-connect (172.19.0.14) port 8083 (#0)
  90. kafka-connect-initializer_1 | > PUT /connectors/elasticsearch-external-tasks/config HTTP/1.1
  91. kafka-connect-initializer_1 | > Host: kafka-connect:8083
  92. kafka-connect-initializer_1 | > User-Agent: curl/7.69.1-DEV
  93. kafka-connect-initializer_1 | > Accept: */*
  94. kafka-connect-initializer_1 | > Content-Type: application/json
  95. kafka-connect-initializer_1 | > Content-Length: 1165
  96. kafka-connect-initializer_1 | >
  97. kafka-connect-initializer_1 | } [1165 bytes data]
  98. kafka-connect-initializer_1 | * upload completely sent off: 1165 out of 1165 bytes
  99. 100 1165 0 0 100 1165 0 967 0:00:01 0:00:01 --:--:-- 967* Mark bundle as not supporting multiuse
  100. kafka-connect-initializer_1 | < HTTP/1.1 201 Created
  101. kafka-connect-initializer_1 | < Date: Thu, 16 Jul 2020 09:20:33 GMT
  102. kafka-connect-initializer_1 | < Location: http://kafka-connect:8083/connectors/elasticsearch-external-tasks
  103. kafka-connect-initializer_1 | < Content-Type: application/json
  104. kafka-connect-initializer_1 | < Content-Length: 1211
  105. kafka-connect-initializer_1 | < Server: Jetty(9.4.24.v20191120)
  106. kafka-connect-initializer_1 | <
  107. kafka-connect-initializer_1 | { [1211 bytes data]
  108. 100 2376 100 1211 100 1165 802 772 0:00:01 0:00:01 --:--:-- 1573
  109. kafka-connect-initializer_1 | * Connection #0 to host kafka-connect left intact
  110. kafka-connect-initializer_1 | Creating connector elasticsearch-external-tasks ... done
  111. backend-compose_kafka-connect-initializer_1 exited with code 0
Add Comment
Please, Sign In to add comment
Public Pastes
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!