diff options
Diffstat (limited to 'src/payload-processor/cmd/main.go')
| -rw-r--r-- | src/payload-processor/cmd/main.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/payload-processor/cmd/main.go b/src/payload-processor/cmd/main.go index 226700d..5faa293 100644 --- a/src/payload-processor/cmd/main.go +++ b/src/payload-processor/cmd/main.go @@ -25,9 +25,9 @@ func main() { Timeout: 10 * time.Second, DualStack: true, }, - Topic: "topic-A", - Partition: 0, - MaxBytes: 10e6, // 10MB + Topic: "topic-A", + GroupID: "group-A", + MaxBytes: 10e6, // 10MB }) processor := processor.NewProcessor(kafka_reader) processor.ProcessMessages() |