kafka-cluster-sr-auth.yaml 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
  1. ---
  2. version: '2'
  3. services:
  4. zookeeper1:
  5. image: confluentinc/cp-zookeeper:5.2.4
  6. environment:
  7. ZOOKEEPER_CLIENT_PORT: 2181
  8. ZOOKEEPER_TICK_TIME: 2000
  9. ports:
  10. - 2182:2181
  11. kafka1:
  12. image: confluentinc/cp-kafka:5.3.1
  13. depends_on:
  14. - zookeeper1
  15. environment:
  16. KAFKA_BROKER_ID: 1
  17. KAFKA_ZOOKEEPER_CONNECT: zookeeper1:2181
  18. KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka1:29092,PLAINTEXT_HOST://localhost:9093
  19. KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
  20. KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
  21. KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
  22. JMX_PORT: 9998
  23. KAFKA_JMX_OPTS: -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Djava.rmi.server.hostname=localhost -Dcom.sun.management.jmxremote.rmi.port=9998
  24. ports:
  25. - 9093:9093
  26. - 9998:9998
  27. schemaregistry1:
  28. image: confluentinc/cp-schema-registry:5.5.0
  29. ports:
  30. - 18085:8085
  31. depends_on:
  32. - zookeeper1
  33. - kafka1
  34. volumes:
  35. - ./jaas:/conf
  36. environment:
  37. SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS: PLAINTEXT://kafka1:29092
  38. SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL: zookeeper1:2181
  39. SCHEMA_REGISTRY_KAFKASTORE_SECURITY_PROTOCOL: PLAINTEXT
  40. SCHEMA_REGISTRY_HOST_NAME: schemaregistry1
  41. SCHEMA_REGISTRY_LISTENERS: http://schemaregistry1:8085
  42. # Default credentials: admin/letmein
  43. SCHEMA_REGISTRY_AUTHENTICATION_METHOD: BASIC
  44. SCHEMA_REGISTRY_AUTHENTICATION_REALM: SchemaRegistryProps
  45. SCHEMA_REGISTRY_AUTHENTICATION_ROLES: admin
  46. SCHEMA_REGISTRY_OPTS: -Djava.security.auth.login.config=/conf/schema_registry.jaas
  47. SCHEMA_REGISTRY_SCHEMA_REGISTRY_INTER_INSTANCE_PROTOCOL: "http"
  48. SCHEMA_REGISTRY_LOG4J_ROOT_LOGLEVEL: INFO
  49. SCHEMA_REGISTRY_KAFKASTORE_TOPIC: _schemas
  50. kafka-init-topics:
  51. image: confluentinc/cp-kafka:5.3.1
  52. volumes:
  53. - ./message.json:/data/message.json
  54. depends_on:
  55. - kafka1
  56. command: "bash -c 'echo Waiting for Kafka to be ready... && \
  57. cub kafka-ready -b kafka1:29092 1 30 && \
  58. kafka-topics --create --topic second.users --partitions 3 --replication-factor 1 --if-not-exists --zookeeper zookeeper1:2181 && \
  59. kafka-topics --create --topic second.messages --partitions 2 --replication-factor 1 --if-not-exists --zookeeper zookeeper1:2181 && \
  60. kafka-console-producer --broker-list kafka1:29092 -topic second.users < /data/message.json'"