diff options
| author | Baitinq <[email protected]> | 2024-05-02 23:33:22 +0200 |
|---|---|---|
| committer | Baitinq <[email protected]> | 2024-05-02 23:45:04 +0200 |
| commit | ff6d61ac3888a023d0be424f76c7b50c8379a75f (patch) | |
| tree | 9874603db6411dca1a5d2916eff57eef9f198914 /src/payload-processor | |
| parent | Switch to kafka :^) (diff) | |
| download | fs-tracer-backend-ff6d61ac3888a023d0be424f76c7b50c8379a75f.tar.gz fs-tracer-backend-ff6d61ac3888a023d0be424f76c7b50c8379a75f.tar.bz2 fs-tracer-backend-ff6d61ac3888a023d0be424f76c7b50c8379a75f.zip | |
rest-api: Write to kafka asynchronously
Diffstat (limited to 'src/payload-processor')
| -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 8e158e9..226700d 100644 --- a/src/payload-processor/cmd/main.go +++ b/src/payload-processor/cmd/main.go @@ -26,7 +26,7 @@ func main() { DualStack: true, }, Topic: "topic-A", - Partition: 0, //TODO: What + Partition: 0, MaxBytes: 10e6, // 10MB }) processor := processor.NewProcessor(kafka_reader) |