流源
建造
./mvnw clean package -DskipTests=true
跑步
运行jar(当Rabbitmq运行时)
java -jar target/stream-source-0.0.1-SNAPSHOT.jar
发送测试信息
curl -v localhost:8080 -d '{"text":"Hello"}' -H 'Content-Type: application/json'
流沉
建造
./mvnw clean package -DskipTests=true
跑步
运行jar(当Rabbitmq运行时)
java -jar target/stream-sink-0.0.1-SNAPSHOT.jar --server.port=8082
发送测试信息
curl -v localhost:8080 -d '{"text":"Hello"}' -H 'Con