diff --git a/austin-stream/src/main/java/com/java3y/austin/stream/constants/AustinFlinkConstant.java b/austin-stream/src/main/java/com/java3y/austin/stream/constants/AustinFlinkConstant.java index b41f5e6..5881070 100644 --- a/austin-stream/src/main/java/com/java3y/austin/stream/constants/AustinFlinkConstant.java +++ b/austin-stream/src/main/java/com/java3y/austin/stream/constants/AustinFlinkConstant.java @@ -14,15 +14,15 @@ public class AustinFlinkConstant { */ public static final String GROUP_ID = "austinLogGroup"; public static final String TOPIC_NAME = "austinTraceLog"; - public static final String BROKER = "austin.kafka"; + public static final String BROKER = "austin-kafka:9092"; /** * redis 配置 * TODO 使用前配置redis ip:port * (真实网络ip,这里不能用配置的hosts,看语雀文档得到真实ip) */ - public static final String REDIS_IP = "austin.redis"; - public static final String REDIS_PORT = "5003"; + public static final String REDIS_IP = "austin-redis"; + public static final String REDIS_PORT = "6379"; public static final String REDIS_PASSWORD = "austin"; diff --git a/docker-compose.yml b/docker-compose.yml index 0c2d42a..0989fc1 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -36,7 +36,7 @@ services: - "/etc/localtime:/etc/localtime" environment: KAFKA_BROKER_ID: 0 - KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://127.0.0.1:9092 + KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://austin-kafka:9092 KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092 KAFKA_ZOOKEEPER_CONNECT: austin-zookepper:2181 KAFKA_CREATE_TOPICS: "austinBusiness:1:1,austinRecall:1:1,austinTraceLog:1:1" @@ -56,6 +56,32 @@ services: - "2181:2181" networks: - app + austin-jobmanager: + image: flink:latest + ports: + - "8081:8081" + command: jobmanager + environment: + - | + FLINK_PROPERTIES= + jobmanager.rpc.address: austin-jobmanager + - SET_CONTAINER_TIMEZONE=true + - CONTAINER_TIMEZONE=Asia/Shanghai + - TZ=Asia/Shanghai + austin-taskmanager: + image: flink:latest + depends_on: + - austin-jobmanager + command: taskmanager + scale: 1 + environment: + - | + FLINK_PROPERTIES= + jobmanager.rpc.address: austin-jobmanager + taskmanager.numberOfTaskSlots: 1 + - SET_CONTAINER_TIMEZONE=true + - CONTAINER_TIMEZONE=Asia/Shanghai + - TZ=Asia/Shanghai austin: build: context: ./