implements rabbitMQ with streamBridge from kafka version

pom.xml

@@ -33,7 +33,7 @@
 		</dependency>
 		<dependency>
 			<groupId>org.springframework.cloud</groupId>
-			<artifactId>spring-cloud-starter-stream-kafka</artifactId>
+			<artifactId>spring-cloud-starter-stream-rabbit</artifactId>
 		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>

src/main/resources/application-local.properties

-spring.application.name=@project.artifactId@
-server.shutdown=graceful
-management.server.port=8080
-spring.jmx.enabled=false
-
-management.endpoint.health.show-components=always
-management.endpoint.health.show-details=always
-
-#server configurations
-server.port=8080
-
-#logs
-logging.pattern.level=%5p [${spring.application.name:},%X{traceId:-},%X{spanId:-}]
-
-# Actuator
-management.endpoints.jmx.exposure.exclude=*
-management.endpoints.web.exposure.include=health,info,metrics,prometheus
-management.info.git.enabled=true
-management.info.java.enabled=true
-management.info.os.enabled=true
-
-# Web
-spring.jackson.default-property-inclusion=non_empty
-spring.jackson.visibility.field=any
-spring.jackson.visibility.getter=none
-spring.jackson.visibility.setter=none
-spring.jackson.visibility.is-getter=none
-
 # Stream
-spring.cloud.stream.kafka.binder.brokers=localhost:9092
-spring.cloud.function.definition=measureConsumer
-spring.cloud.stream.kafka.binder.configuration.key.serializer=org.apache.kafka.common.serialization.StringSerializer
-
-#Producer
-#spring.cloud.stream.bindings.measureProducer.destination=measure
-
-
-## Consumer
-spring.cloud.stream.bindings.measureConsumer-in-0.destination=measure
-spring.cloud.stream.bindings.measureConsumer-in-0.group=measureGroup
-
+#spring.cloud.stream.kafka.binder.brokers=localhost:9092
+#spring.cloud.stream.kafka.binder.configuration.key.serializer=org.apache.kafka.common.serialization.StringSerializer
 
 # Redis
 spring.data.redis.host=localhost
 spring.data.redis.port=6379
 spring.data.redis.password=pa55word
-spring.data.redis.jedis.pool.max-active=15
-spring.data.redis.jedis.pool.min-idle=3
-spring.cache.redis.time-to-live=1m
+
+# RabbitMQ Configuration
+spring.rabbitmq.host=localhost
+spring.rabbitmq.port=5672
+spring.rabbitmq.username=user
+spring.rabbitmq.password=p@ssword
 
 #GrpcEnpoint
 grpc.adapter.host = localhost

src/main/resources/application.properties

@@ -19,27 +19,14 @@ logging.pattern.level=%5p [${spring.application.name:},%X{traceId:-},%X{spanId:-
 
 # Web
 spring.jackson.default-property-inclusion=non_empty
-spring.jackson.visibility.field=any
-spring.jackson.visibility.getter=none
-spring.jackson.visibility.setter=none
-spring.jackson.visibility.is-getter=none
-
-#Producer
-spring.cloud.stream.bindings.measureProducer.destination=measure
 
 # Stream
-spring.cloud.stream.kafka.binder.brokers=${SPRING_CLOUD_STREAM_KAFKA_BINDER_BROKERS}
 spring.cloud.function.definition=measureConsumer
-spring.cloud.stream.kafka.binder.configuration.key.serializer=org.apache.kafka.common.serialization.StringSerializer
 
 ## Consumer
 spring.cloud.stream.bindings.measureConsumer-in-0.destination=measure
-spring.cloud.stream.bindings.measureConsumer-in-0.group=measureGroup
-
+spring.cloud.stream.bindings.measureConsumer-in-0.group=${spring.application.name}
 # Redis
-#spring.data.redis.host=localhost
-#spring.data.redis.port=6379
-#spring.data.redis.password=pa55word
 spring.data.redis.jedis.pool.max-active=15
 spring.data.redis.jedis.pool.min-idle=3
 spring.cache.redis.time-to-live=1m