diff --git a/austin-web/src/main/resources/application-test.properties b/austin-web/src/main/resources/application-test.properties index ce2781f..0057ec2 100644 --- a/austin-web/src/main/resources/application-test.properties +++ b/austin-web/src/main/resources/application-test.properties @@ -15,10 +15,10 @@ austin.redis.port=6379 austin.redis.password=austin # TODO choose : kafka/eventBus/rocketMq/rabbitMq, default eventBus -austin.mq.pipeline=eventBus +austin.mq.pipeline=kafka # todo [kafka] ip/port【optional】, if austin.mq.pipeline=kafka 【must】 -austin.kafka.ip=austin.kafka +austin.kafka.ip=austin-kafka austin.kafka.port=9092 # todo [rocketMq] 【optional】, if austin.mq.pipeline=rocketMq【must】 diff --git a/austin-web/src/main/resources/application.properties b/austin-web/src/main/resources/application.properties index 3c2b8f6..4d18dcb 100644 --- a/austin-web/src/main/resources/application.properties +++ b/austin-web/src/main/resources/application.properties @@ -22,8 +22,8 @@ spring.kafka.consumer.enable-auto-commit=true ### austin.business.topic.name=austinBusiness austin.business.recall.topic.name=austinRecall -austin.business.recall.group.name=recallGroupId austin.business.log.topic.name=austinTraceLog +austin.business.recall.group.name=recallGroupId ### TODO kafka tag filter,if you need, replace tagIdValue ,eg:com.java3y.austin.yyy austin.business.tagId.key=kafka_tag_id austin.business.tagId.value=com.java3y.austin.3y diff --git a/docker-compose.yml b/docker-compose.yml index 702647d..e919b98 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -26,7 +26,34 @@ services: volumes: - ./docker/redis/redis.conf:/usr/local/etc/redis/redis.conf:rw command: - /bin/bash -c "redis-server /usr/local/etc/redis/redis.conf" + /bin/bash -c "redis-server /usr/local/etc/redis/redis.conf" + networks: + - app + austin-kafka: + image: wurstmeister/kafka + container_name: kafka + volumes: + - "/etc/localtime:/etc/localtime" + environment: + KAFKA_BROKER_ID: 0 + KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://127.0.0.1:9092 + KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092 + KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 + KAFKA_CREATE_TOPICS: "austinBusiness:1:1,austinRecall:1:1,austinTraceLog:1:1" + KAFKA_HEAP_OPTS: -Xmx256M -Xms256M + ports: + - "9092:9092" + depends_on: + - austin-zookepper + networks: + - app + austin-zookepper: + image: wurstmeister/zookeeper + container_name: austin-zookepper + volumes: + - "/etc/localtime:/etc/localtime" + ports: + - "2181:2181" networks: - app austin: @@ -39,6 +66,7 @@ services: depends_on: - austin-redis - austin-mysql + - austin-kafka networks: - app networks: