diff options
| author | Baitinq <manuelpalenzuelamerino@gmail.com> | 2024-05-05 15:29:29 +0200 |
|---|---|---|
| committer | Baitinq <manuelpalenzuelamerino@gmail.com> | 2024-05-05 15:29:29 +0200 |
| commit | 757257cb229afc004778e681d3dbdbe9b42e186e (patch) | |
| tree | c47825183de2cc2f9a4e6a5f94ebf17a92ff5537 | |
| parent | k8s: fix metallb config resources not being applied (diff) | |
| download | fs-tracer-backend-757257cb229afc004778e681d3dbdbe9b42e186e.tar.gz fs-tracer-backend-757257cb229afc004778e681d3dbdbe9b42e186e.tar.bz2 fs-tracer-backend-757257cb229afc004778e681d3dbdbe9b42e186e.zip | |
payload-processor: print message partition
| -rw-r--r-- | src/payload-processor/processor/processor.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/payload-processor/processor/processor.go b/src/payload-processor/processor/processor.go index fc6792a..4b03bd5 100644 --- a/src/payload-processor/processor/processor.go +++ b/src/payload-processor/processor/processor.go @@ -73,6 +73,6 @@ func (p Processor) process(ctx context.Context, cancel context.CancelFunc) { } func (p Processor) handleMessage(m kafka.Message) error { - fmt.Printf("(%s): message at offset %d: %s = %s\n", time.Now().String(), m.Offset, string(m.Key), string(m.Value)) + fmt.Printf("(%s): message at paritition %d: offset %d: %s = %s\n", time.Now().String(), m.Partition, m.Offset, string(m.Key), string(m.Value)) return nil } |