Skip to content

Commit f7a664c

Browse files
feature(kpi): Application audit ingestion performance improvement (PROD) (#157)
1 parent f77343e commit f7a664c

File tree

2 files changed

+8
-1
lines changed

2 files changed

+8
-1
lines changed

commons/prod-analytics/configmaps/kafka-configmap.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ data:
77
KAFKA_BROKERS: "b-1.interopplatformevents.gfkljw.c4.kafka.eu-south-1.amazonaws.com:9098,b-2.interopplatformevents.gfkljw.c4.kafka.eu-south-1.amazonaws.com:9098,b-3.interopplatformevents.gfkljw.c4.kafka.eu-south-1.amazonaws.com:9098"
88
KAFKA_AVERAGE_MESSAGE_SIZE_IN_BYTES: "1000"
99
KAFKA_MAX_WAIT_BATCH_MILLIS: "60000"
10-
KAFKA_MESSAGES_TO_READ_PER_BATCH: "1000"
10+
KAFKA_MESSAGES_TO_READ_PER_BATCH: "10000"
1111
KAFKA_TOPIC_STARTING_OFFSET: "earliest"
1212
APPLICATION_AUDIT_TOPIC: "prod_application.audit"
1313
CATALOG_TOPIC: "event-store.prod_catalog.events"

microservices/application-audit-analytics-writer/prod-analytics/values.yaml

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,13 @@ service:
99
configmap:
1010
SERVICE_NAME: pagopa-interop-application-audit-analytics-writer-prod
1111
KAFKA_GROUP_ID: "{{.Values.namespace}}-application-audit-analytics-writer"
12+
ACCUMULATOR_MAX_MESSAGES: 1000000
13+
ACCUMULATOR_FLUSH_TIMEOUT_MS: 60000
14+
S3_COPY_BUCKET: interop-analytics-etl-application-audit-{{.Values.local.env}}-es1
15+
S3_DELETE_AFTER_COPY: true
16+
REDSHIFT_COPY_IAM_ROLE_ARN: "arn:aws:iam::697818730278:role/interop-analytics-redshift-s3-copy-{{.Values.local.env}}"
17+
GZ_COMPRESSION_LEVEL: 3
18+
DB_INGEST_MODE: "COPY"
1219

1320
deployment:
1421
replicas: 0

0 commit comments

Comments
 (0)