Files
datawave/docker/config/application-querymessaging.yml
611062262b 2417 qr dedicated rabbitmq (#2522)
run a dedicated rabbitmq for the query results

Co-authored-by: Christopher Gross cogross <[email protected]>
Co-authored-by: Ivan Bella <[email protected]>
2026-06-02 15:15:58 +00:00

39 lines
1.8 KiB
YAML
Executable File

# This profile should be included by any service which depends on the query starter and
# wants to read/write query stats from/to the query storage cache, or read/write query
# results from/to the query results messaging backend.
datawave:
query:
messaging:
backend: ${messaging.backend}
rabbitmq:
maxMessageSizeBytes: ${messaging.maxMessageSizeBytes}
# enable the following configuration if you want to use an independent, dedicated rabbitmq cluster for query (i.e. not the default spring one)
useDedicatedInstance: ${USE_DEDICATED_INSTANCE:false}
instanceSettings:
host: ${QUERY_RABBIT_HOST:query-rabbitmq}
port: ${QUERY_RABBIT_PORT:5672}
publisherConfirmType: SIMPLE
# Note - spring doesn't like it when you enable publisherConfirms for the SIMPLE confirm type...
publisherConfirms: false
publisherReturns: true
qr-rabbitmq:
maxMessageSizeBytes: ${messaging.maxMessageSizeBytes}
useDedicatedInstance: ${USE_DEDICATED_INSTANCE:false}
instanceSettings:
host: ${QUERY_RABBIT_HOST:query-rabbitmq}
port: ${QUERY_RABBIT_PORT:5673}
publisherConfirmType: SIMPLE
# Note - spring doesn't like it when you enable publisherConfirms for the SIMPLE confirm type...
publisherConfirms: false
publisherReturns: true
kafka:
partitions: 2
# enable the following configuration if you want to use an independent, dedicated kafka cluster for query (i.e. not the default spring one)
useDedicatedInstance: ${USE_DEDICATED_INSTANCE:false}
instanceSettings:
bootstrapServers: ${QUERY_KAFKA_HOST:query-kafka}:${QUERY_KAFKA_PORT:9092}
autoOffsetReset: earliest
enableAutoCommit: false
allowAutoCreateTopics: false