diff options
| author | Baitinq <manuelpalenzuelamerino@gmail.com> | 2024-05-04 21:02:04 +0200 |
|---|---|---|
| committer | Baitinq <manuelpalenzuelamerino@gmail.com> | 2024-05-04 21:02:04 +0200 |
| commit | 7347e1d37464bbe9477d10bac70f102b43585dc1 (patch) | |
| tree | 3fbb5b4b346173b74e01c61e32400007d299699d /src/payload-processor/cmd/main.go | |
| parent | go mod tidy (diff) | |
| download | fs-tracer-backend-7347e1d37464bbe9477d10bac70f102b43585dc1.tar.gz fs-tracer-backend-7347e1d37464bbe9477d10bac70f102b43585dc1.tar.bz2 fs-tracer-backend-7347e1d37464bbe9477d10bac70f102b43585dc1.zip | |
payload-processor: add concurrency
Diffstat (limited to 'src/payload-processor/cmd/main.go')
| -rw-r--r-- | src/payload-processor/cmd/main.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/payload-processor/cmd/main.go b/src/payload-processor/cmd/main.go index 5faa293..2604d8e 100644 --- a/src/payload-processor/cmd/main.go +++ b/src/payload-processor/cmd/main.go @@ -29,6 +29,6 @@ func main() { GroupID: "group-A", MaxBytes: 10e6, // 10MB }) - processor := processor.NewProcessor(kafka_reader) + processor := processor.NewProcessor(kafka_reader, 4) processor.ProcessMessages() } |