Skip to main content

Kafka Cluster

Connection Info

Bootstrap Server: pkc-ldvr1.asia-southeast1.gcp.confluent.cloud:9092

Consumer Groups & Topics

SpcLisBe (LIS Backend)

TopicPartitionsRetention
c1.spc.lis.sample-status.prod157d
c1.spc.lis.work-order.prod47d
c1.spc.lis.auto-verify.prod37d
c1.spc.lis.qc-data.prod37d
c1.spc.lis.attune-status.prod37d
c1.spc.lis.test-result.sync.prod37d
c1.spc.lis.vid-attachment-upload.prod37d
c1.spc.pdf-generate.webhook.prod157d
c1.spc.pos.orders.prod37d
IrisTestResult47d
StatusAttune27d

Total: 11 topics, 58 partitions

PatTestResultBeGroup (Patient Test Results)

TopicPartitionsRetention
c1.pat.test-result.prod207d
c1.pat.test-result.refdoc.prod77d
c1.pat.test-result.walkin.prod37d
c1.pat.notification-test-result.prod67d
c1.pat.test-master-data.prod67d
c1.pat.copper.configuration.prod37d
c1.patient.appointment-sync.prod37d
c1.patient.dtc.homekit.register.prod37d
c1.patient.imaging-service.report.prod37d
c1.spc.lis.test-result.prod37d
c1.sync-testmaster.prod37d
customer37d
Bookings230d
lis.testresult47d

Total: 14 topics, 69 partitions

PatBookingBeGroup (Patient Booking)

TopicPartitionsRetention
c1.pat.booking.recommend.test.prod37d
c1.pat.appointment.update.prod37d
Bookings230d

Total: 3 topics, 8 partitions

PatNotificationBeGroup (Patient Notifications)

TopicPartitionsRetention
c1.patient.notification.prod37d
c1.patient.notification.update.prod37d
c1.patient.testresult.notification.prod37d

Total: 3 topics, 9 partitions

SapocheProd (Main Sapoche App)

TopicPartitionsRetention
TestResult37d
Orders230d
Bookings230d
Status27d
IrisTestResult47d
TestMasterGroup27d
TestMasterInvestigation27d

Total: 7 topics, 17 partitions

ImpProduction (IMP Application)

TopicPartitionsRetention
c1.imp.worker.prod157d
c1.imp.worker.order.prod47d
Employee37d
InventoryProductMaster27d
InventoryStockOut27d
InventoryStockUpdate27d
InventoryConsumptionMapping27d
OTRecord27d
Payroll27d

Total: 9 topics, 36 partitions

RfdDoctorKYCGroup (Doctor KYC)

TopicPartitionsRetention
c1.rfd.doctor-kyc.kyc-event.prod37d
c1.rfd.doctor-kyc.send-otp.prod37d

Total: 2 topics, 6 partitions

RfdDoctorStatementBeGroup (Doctor Statements)

TopicPartitionsRetention
c1.rfd.doctor-statement.generate-statement-pdf.prod37d
c1.rfd.doctor-statement.download-statement-otp.prod37d
c1.rfd.doctor-statement.link-event-tracking.prod37d
c1.int.erp.doctor-statement.prod37d

Total: 4 topics, 12 partitions

RfdNotificationBeGroup (Doctor Notifications)

TopicPartitionsRetention
c1.rfd-send-notification.prod37d
c1.rfd.notification.push-notification.prod37d

Total: 2 topics, 6 partitions

NetsuiteConsumer (NetSuite Integration)

TopicPartitionsRetention
c1.int.erp.doctor-statement.prod37d
c1.int.crm-integration.customer.prod37d

Total: 2 topics, 6 partitions

spc--pos--be (POS Backend)

TopicPartitionsRetention
c1.spc.pos.orders.prod37d
Orders230d

Total: 2 topics, 5 partitions

PDF_SERVICE_PRODUCTION (PDF Generation)

TopicPartitionsRetention
c1.spc.pdf-generate.webhook.prod157d

Total: 1 topic, 15 partitions

CLI Commands

List all consumer groups

/opt/homebrew/Cellar/kafka/4.1.0/bin/kafka-consumer-groups \
--command-config prod.consumer.properties \
--bootstrap-server pkc-ldvr1.asia-southeast1.gcp.confluent.cloud:9092 \
--list

Check consumer group lag

/opt/homebrew/Cellar/kafka/4.1.0/bin/kafka-consumer-groups \
--command-config prod.consumer.properties \
--bootstrap-server pkc-ldvr1.asia-southeast1.gcp.confluent.cloud:9092 \
--describe \
--group SpcLisBe

List all topics

/opt/homebrew/Cellar/kafka/4.1.0/bin/kafka-topics \
--command-config prod.consumer.properties \
--bootstrap-server pkc-ldvr1.asia-southeast1.gcp.confluent.cloud:9092 \
--list

Describe topic (partition count)

/opt/homebrew/Cellar/kafka/4.1.0/bin/kafka-topics \
--command-config prod.consumer.properties \
--bootstrap-server pkc-ldvr1.asia-southeast1.gcp.confluent.cloud:9092 \
--describe \
--topic c1.spc.lis.sample-status.prod

All Topics

Patient Services (PAT) - 10 topics

  • c1.pat.booking.recommend.test.prod (3 partitions)
  • c1.pat.notification-test-result.prod (6 partitions)
  • c1.pat.test-master-data.prod (6 partitions)
  • c1.pat.test-result.prod (20 partitions)
  • c1.pat.test-result.recommend.prod (3 partitions)
  • c1.pat.test-result.refdoc.prod (7 partitions)
  • c1.pat.test-result.walkin.prod (3 partitions)
  • c1.pat.appointment.update.prod (3 partitions)
  • c1.pat.clear-order-data.prod (3 partitions)
  • c1.pat.copper.configuration.prod (3 partitions)

Patient Portal - 8 topics

  • c1.patient.appointment-sync.prod (3 partitions)
  • c1.patient.dtc.homekit.register.prod (3 partitions)
  • c1.patient.imaging-service.report.prod (3 partitions)
  • c1.patient.notification.prod (3 partitions)
  • c1.patient.notification.update.prod (3 partitions)
  • c1.patient.retry.message.prod (3 partitions)
  • c1.patient.test-result.update-result.prod (3 partitions)
  • c1.patient.testresult.notification.prod (3 partitions)

Sapoche Clinic (SPC) - 10 topics

  • c1.spc.lis.sample-status.prod (15 partitions)
  • c1.spc.lis.work-order.prod (4 partitions)
  • c1.spc.lis.auto-verify.prod (3 partitions)
  • c1.spc.lis.qc-data.prod (3 partitions)
  • c1.spc.lis.attune-status.prod (3 partitions)
  • c1.spc.lis.test-result.sync.prod (3 partitions)
  • c1.spc.lis.test-result.prod (3 partitions)
  • c1.spc.lis.vid-attachment-upload.prod (3 partitions)
  • c1.spc.pdf-generate.webhook.prod (15 partitions)
  • c1.spc.pos.orders.prod (3 partitions)

Referring Doctor (RFD) - 8 topics

  • c1.rfd-send-notification.prod (3 partitions)
  • c1.rfd.doctor-kyc.kyc-event.prod (3 partitions)
  • c1.rfd.doctor-kyc.send-otp.prod (3 partitions)
  • c1.rfd.doctor-statement.download-statement-otp.prod (3 partitions)
  • c1.rfd.doctor-statement.generate-statement-pdf.prod (3 partitions)
  • c1.rfd.doctor-statement.link-event-tracking.prod (3 partitions)
  • c1.rfd.doctor-test-result.event-tracking.prod (3 partitions)
  • c1.rfd.notification.push-notification.prod (3 partitions)

Integrations - 5 topics

  • c1.imp.worker.order.prod (4 partitions)
  • c1.imp.worker.prod (15 partitions)
  • c1.int.crm-integration.customer.prod (3 partitions)
  • c1.int.erp.doctor-statement.prod (3 partitions)
  • c1.appointment.notification.prod (3 partitions)

Legacy Topics (No c1 prefix) - 19 topics

  • Bookings (2 partitions)
  • Orders (2 partitions)
  • Status (2 partitions)
  • StatusAttune (2 partitions)
  • Employee (3 partitions)
  • Payroll (2 partitions)
  • OTRecord (2 partitions)
  • InventoryConsumptionMapping (2 partitions)
  • InventoryProductMaster (2 partitions)
  • InventoryStockOut (2 partitions)
  • InventoryStockUpdate (2 partitions)
  • IrisTestResult (4 partitions)
  • Pricelist (2 partitions)
  • Promotion (2 partitions)
  • TestMasterGroup (2 partitions)
  • TestMasterInvestigation (2 partitions)
  • TestResult (3 partitions)
  • activities (2 partitions)
  • customer (3 partitions)
  • lis.testresult (4 partitions)

Total: 117 topics