about summary refs log tree commit diff
path: root/src/payload-processor/processor/processor.go (follow)
Commit message (Expand)AuthorAgeFilesLines
* payload-processor: fmtBaitinq2024-05-271-2/+4
* payload-processor: always commit to kafka (for now)Baitinq2024-05-271-2/+9
* payload-processor: insert to the file tableBaitinq2024-05-271-1/+20
* payloads-processor: connect to DB and insert dummy dataBaitinq2024-05-111-3/+11
* payload-processor: print message partitionBaitinq2024-05-051-1/+1
* payload-processor: set up testingBaitinq2024-05-041-1/+10
* payload-processor: add concurrencyBaitinq2024-05-041-8/+26
* payload-processor: use consumer group and properly handle application shutdownBaitinq2024-05-041-2/+18
* payload-processor: fmtBaitinq2024-05-041-1/+1
* payload-processor: print current time when processingBaitinq2024-05-031-1/+2
* Switch to kafka :^)Baitinq2024-05-021-19/+14
* misc: clean up unnecessary use of ptrsBaitinq2024-05-021-3/+3
* payload-processor: add stubBaitinq2024-05-021-0/+39