Skip to content

Commit

Permalink
KOGITO-9561: Jobs service kafka and http messaging modularization
Browse files Browse the repository at this point in the history 
    - keep the events-support profile for backward compatibility
  • Loading branch information
@wmedvede
wmedvede committed Jul 21, 2023
1 parent 0d6fe8e commit a2fc6e3
Showing 1 changed file with 25 additions and 25 deletions.
50 changes: 25 additions & 25 deletions ...e/jobs-service-messaging-kafka/src/main/resources/META-INF/microprofile-config.properties
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
# This file contains the default configurations for Kafka.

# Kafka global default configurations.
%kafka-events-support.kafka.bootstrap.servers=localhost:9092
%events-support,kafka-events-support.kafka.bootstrap.servers=localhost:9092

# enabling in-memory connector in case kafka is not enabled, to avoid issues with DI
mp.messaging.outgoing.kogito-job-service-job-status-events.connector=smallrye-in-memory
Expand All @@ -30,35 +30,35 @@ kogito.jobs-service.kafka.job-status-change-events-topic=kogito-jobs-events
kogito.jobs-service.kafka.events-api=false

# Job status change events are automatically enabled with the profile: kafka-events-support (-Dquarkus.profile=kafka-events-support)
%kafka-events-support.kogito.jobs-service.kafka.job-status-change-events=true
%kafka-events-support.kogito.jobs-service.kafka.job-status-change-events-topic=kogito-jobs-events
%events-support,kafka-events-support.kogito.jobs-service.kafka.job-status-change-events=true
%events-support,kafka-events-support.kogito.jobs-service.kafka.job-status-change-events-topic=kogito-jobs-events

# Job service eventing API is automatically enabled with the profile: kafka-events-support (-Dquarkus.profile=kafka-events-support)
%kafka-events-support.kogito.jobs-service.kafka.events-api=true
%events-support,kafka-events-support.kogito.jobs-service.kafka.events-api=true

# Kafka Job status change events configuration.
%kafka-events-support.mp.messaging.outgoing.kogito-job-service-job-status-events.connector=smallrye-kafka
%kafka-events-support.mp.messaging.outgoing.kogito-job-service-job-status-events.topic=${kogito.jobs-service.kafka.job-status-change-events-topic}
%kafka-events-support.mp.messaging.outgoing.kogito-job-service-job-status-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
%events-support,kafka-events-support.mp.messaging.outgoing.kogito-job-service-job-status-events.connector=smallrye-kafka
mp.messaging.outgoing.kogito-job-service-job-status-events.topic=${kogito.jobs-service.kafka.job-status-change-events-topic}
mp.messaging.outgoing.kogito-job-service-job-status-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer

# Kafka V1 Eventing API incoming events.
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events.connector=smallrye-kafka
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events.enabled=${kogito.jobs-service.kafka.events-api}
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events.topic=kogito-job-service-job-request-events
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events.value.deserializer=org.kie.kogito.jobs.service.messaging.kafka.CloudEventDeserializer
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events.client.id=kogito-jobs-service
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events.group.id=kogito-jobs-service
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events.enable.auto.commit=false
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events.auto.offset.reset=earliest
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events.isolation.level=read_committed
mp.messaging.incoming.kogito-job-service-job-request-events.connector=smallrye-kafka
mp.messaging.incoming.kogito-job-service-job-request-events.enabled=${kogito.jobs-service.kafka.events-api}
mp.messaging.incoming.kogito-job-service-job-request-events.topic=kogito-job-service-job-request-events
mp.messaging.incoming.kogito-job-service-job-request-events.value.deserializer=org.kie.kogito.jobs.service.messaging.kafka.CloudEventDeserializer
mp.messaging.incoming.kogito-job-service-job-request-events.client.id=kogito-jobs-service
mp.messaging.incoming.kogito-job-service-job-request-events.group.id=kogito-jobs-service
mp.messaging.incoming.kogito-job-service-job-request-events.enable.auto.commit=false
mp.messaging.incoming.kogito-job-service-job-request-events.auto.offset.reset=earliest
mp.messaging.incoming.kogito-job-service-job-request-events.isolation.level=read_committed

# Kafka V2 Eventing API incoming events.
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events-v2.connector=smallrye-kafka
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events-v2.enabled=${kogito.jobs-service.kafka.events-api}
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events-v2.topic=kogito-job-service-job-request-events-v2
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events-v2.value.deserializer=org.kie.kogito.jobs.service.messaging.kafka.CloudEventDeserializer
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events-v2.client.id=kogito-jobs-service-v2
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events-v2.group.id=kogito-jobs-service
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events-v2.enable.auto.commit=false
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events-v2.auto.offset.reset=earliest
%kafka-events-support.mp.messaging.incoming.kogito-job-service-job-request-events-v2.isolation.level=read_committed
mp.messaging.incoming.kogito-job-service-job-request-events-v2.connector=smallrye-kafka
mp.messaging.incoming.kogito-job-service-job-request-events-v2.enabled=${kogito.jobs-service.kafka.events-api}
mp.messaging.incoming.kogito-job-service-job-request-events-v2.topic=kogito-job-service-job-request-events-v2
mp.messaging.incoming.kogito-job-service-job-request-events-v2.value.deserializer=org.kie.kogito.jobs.service.messaging.kafka.CloudEventDeserializer
mp.messaging.incoming.kogito-job-service-job-request-events-v2.client.id=kogito-jobs-service-v2
mp.messaging.incoming.kogito-job-service-job-request-events-v2.group.id=kogito-jobs-service
mp.messaging.incoming.kogito-job-service-job-request-events-v2.enable.auto.commit=false
mp.messaging.incoming.kogito-job-service-job-request-events-v2.auto.offset.reset=earliest
mp.messaging.incoming.kogito-job-service-job-request-events-v2.isolation.level=read_committed

0 comments on commit a2fc6e3

Please sign in to comment.