SHARE
TWEET

Untitled

a guest May 19th, 2019 57 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. FROM confluentinc/cp-kafka-connect-base:5.2.1
  2. ENV CONNECT_PLUGIN_PATH /usr/share/java/kafka-connect-randomlong
  3.  
  4. ENV KAFKA_JMX_PORT 5555
  5. ENV CONNECT_REST_ADVERTISED_HOST_NAME (v1:status.podIP)
  6. ENV CONNECT_INTERNAL_KEY_CONVERTER org.apache.kafka.connect.json.JsonConverter
  7. ENV CONNECT_INTERNAL_VALUE_CONVERTER org.apache.kafka.connect.json.JsonConverter
  8. ENV CONNECT_BOOTSTRAP_SERVERS PLAINTEXT://<your-cp-kafka-headless-pod-name>:9092
  9. ENV CONNECT_GROUP_ID connect-randomlong-cluster
  10. ENV CONNECT_KEY_CONVERTER org.apache.kafka.connect.storage.StringConverter
  11. ENV CONNECT_VALUE_CONVERTER org.apache.kafka.connect.storage.StringConverter
  12. ENV CONNECT_KEY_CONVERTER_SCHEMAS_ENABLE true
  13. ENV CONNECT_VALUE_CONVERTER_SCHEMAS_ENABLE true
  14. ENV CONNECT_OFFSET_STORAGE_TOPIC connect-randomlong-offsets
  15. ENV CONNECT_OFFSET_STORAGE_REPLICATION_FACTOR 1
  16. ENV CONNECT_CONFIG_STORAGE_TOPIC connect-randomlong-configs
  17. ENV CONNECT_CONFIG_STORAGE_REPLICATION_FACTOR 1
  18. ENV CONNECT_STATUS_STORAGE_TOPIC connect-randomlong-status
  19. ENV CONNECT_STATUS_STORAGE_REPLICATION_FACTOR 1
  20. ENV CONNECT_OFFSET_FLUSH_INTERVAL_MS 10000
  21.  
  22. COPY build/libs/connector-all.jar /usr/share/java/kafka-connect-randomlong/connector-all.jar
RAW Paste Data
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
 
Top