Skip to content

Commit

Permalink
feat: add contact-channels new topic and consumer + producer (#411)
Browse files Browse the repository at this point in the history
  • Loading branch information
vitorf7 committed Jul 8, 2024
1 parent 5ec418f commit d993e2f
Showing 1 changed file with 23 additions and 0 deletions.
23 changes: 23 additions & 0 deletions dev-aws/kafka-shared-msk/contact-channels/contact-channels.tf
Original file line number Diff line number Diff line change
Expand Up @@ -140,6 +140,20 @@ resource "kafka_topic" "validated_intents_v2" {
}
}

resource "kafka_topic" "interactions_state_events" {
name = "contact-channels.interactions_state_events"

replication_factor = 3
partitions = 3

config = {
"retention.ms" = "86400000" # 24 hours
"max.message.bytes" = "1048576" # 1MB
"compression.type" = "zstd"
"cleanup.policy" = "compact"
}
}

## TLS App

# Consume from contact-channels.genesys_eb_events for Last Contact Digital Survey Projector
Expand Down Expand Up @@ -279,3 +293,12 @@ module "survey_responses_bq_projector" {
consume_topics = [kafka_topic.tracking_events.name]
consume_groups = ["contact-channels.survey-responses-bq-projector"]
}

# Consume from contact-channels.tracking_events
module "agent_state_builder" {
source = "../../../modules/tls-app"
cert_common_name = "contact-channels/agent-state-builder"
consume_topics = [kafka_topic.genesys_eb_events.name]
consume_groups = ["contact-channels.eb-kafka-agent-state-builder"]
produce_topics = [kafka_topic.interactions_state_events.name]
}

0 comments on commit d993e2f

Please sign in to comment.