Kafka Cluster
Connection Info
Bootstrap Server: pkc-ldvr1.asia-southeast1.gcp.confluent.cloud:9092
Consumer Groups & Topics
SpcLisBe (LIS Backend)
| Topic | Partitions | Retention |
|---|---|---|
| c1.spc.lis.sample-status.prod | 15 | 7d |
| c1.spc.lis.work-order.prod | 4 | 7d |
| c1.spc.lis.auto-verify.prod | 3 | 7d |
| c1.spc.lis.qc-data.prod | 3 | 7d |
| c1.spc.lis.attune-status.prod | 3 | 7d |
| c1.spc.lis.test-result.sync.prod | 3 | 7d |
| c1.spc.lis.vid-attachment-upload.prod | 3 | 7d |
| c1.spc.pdf-generate.webhook.prod | 15 | 7d |
| c1.spc.pos.orders.prod | 3 | 7d |
| IrisTestResult | 4 | 7d |
| StatusAttune | 2 | 7d |
Total: 11 topics, 58 partitions
PatTestResultBeGroup (Patient Test Results)
| Topic | Partitions | Retention |
|---|---|---|
| c1.pat.test-result.prod | 20 | 7d |
| c1.pat.test-result.refdoc.prod | 7 | 7d |
| c1.pat.test-result.walkin.prod | 3 | 7d |
| c1.pat.notification-test-result.prod | 6 | 7d |
| c1.pat.test-master-data.prod | 6 | 7d |
| c1.pat.copper.configuration.prod | 3 | 7d |
| c1.patient.appointment-sync.prod | 3 | 7d |
| c1.patient.dtc.homekit.register.prod | 3 | 7d |
| c1.patient.imaging-service.report.prod | 3 | 7d |
| c1.spc.lis.test-result.prod | 3 | 7d |
| c1.sync-testmaster.prod | 3 | 7d |
| customer | 3 | 7d |
| Bookings | 2 | 30d |
| lis.testresult | 4 | 7d |
Total: 14 topics, 69 partitions
PatBookingBeGroup (Patient Booking)
| Topic | Partitions | Retention |
|---|---|---|
| c1.pat.booking.recommend.test.prod | 3 | 7d |
| c1.pat.appointment.update.prod | 3 | 7d |
| Bookings | 2 | 30d |
Total: 3 topics, 8 partitions
PatNotificationBeGroup (Patient Notifications)
| Topic | Partitions | Retention |
|---|---|---|
| c1.patient.notification.prod | 3 | 7d |
| c1.patient.notification.update.prod | 3 | 7d |
| c1.patient.testresult.notification.prod | 3 | 7d |
Total: 3 topics, 9 partitions
SapocheProd (Main Sapoche App)
| Topic | Partitions | Retention |
|---|---|---|
| TestResult | 3 | 7d |
| Orders | 2 | 30d |
| Bookings | 2 | 30d |
| Status | 2 | 7d |
| IrisTestResult | 4 | 7d |
| TestMasterGroup | 2 | 7d |
| TestMasterInvestigation | 2 | 7d |
Total: 7 topics, 17 partitions
ImpProduction (IMP Application)
| Topic | Partitions | Retention |
|---|---|---|
| c1.imp.worker.prod | 15 | 7d |
| c1.imp.worker.order.prod | 4 | 7d |
| Employee | 3 | 7d |
| InventoryProductMaster | 2 | 7d |
| InventoryStockOut | 2 | 7d |
| InventoryStockUpdate | 2 | 7d |
| InventoryConsumptionMapping | 2 | 7d |
| OTRecord | 2 | 7d |
| Payroll | 2 | 7d |
Total: 9 topics, 36 partitions
RfdDoctorKYCGroup (Doctor KYC)
| Topic | Partitions | Retention |
|---|---|---|
| c1.rfd.doctor-kyc.kyc-event.prod | 3 | 7d |
| c1.rfd.doctor-kyc.send-otp.prod | 3 | 7d |
Total: 2 topics, 6 partitions
RfdDoctorStatementBeGroup (Doctor Statements)
| Topic | Partitions | Retention |
|---|---|---|
| c1.rfd.doctor-statement.generate-statement-pdf.prod | 3 | 7d |
| c1.rfd.doctor-statement.download-statement-otp.prod | 3 | 7d |
| c1.rfd.doctor-statement.link-event-tracking.prod | 3 | 7d |
| c1.int.erp.doctor-statement.prod | 3 | 7d |
Total: 4 topics, 12 partitions
RfdNotificationBeGroup (Doctor Notifications)
| Topic | Partitions | Retention |
|---|---|---|
| c1.rfd-send-notification.prod | 3 | 7d |
| c1.rfd.notification.push-notification.prod | 3 | 7d |
Total: 2 topics, 6 partitions
NetsuiteConsumer (NetSuite Integration)
| Topic | Partitions | Retention |
|---|---|---|
| c1.int.erp.doctor-statement.prod | 3 | 7d |
| c1.int.crm-integration.customer.prod | 3 | 7d |
Total: 2 topics, 6 partitions
spc--pos--be (POS Backend)
| Topic | Partitions | Retention |
|---|---|---|
| c1.spc.pos.orders.prod | 3 | 7d |
| Orders | 2 | 30d |
Total: 2 topics, 5 partitions
PDF_SERVICE_PRODUCTION (PDF Generation)
| Topic | Partitions | Retention |
|---|---|---|
| c1.spc.pdf-generate.webhook.prod | 15 | 7d |
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