diff options
| author | Baitinq <manuelpalenzuelamerino@gmail.com> | 2024-05-04 11:35:56 +0200 |
|---|---|---|
| committer | Baitinq <manuelpalenzuelamerino@gmail.com> | 2024-05-04 11:35:56 +0200 |
| commit | a68b8738dd91b1cd30b677df1055da0e1871dc38 (patch) | |
| tree | 1e04b192ce9c3099c574e32097f175a014c6b51b | |
| parent | misc: add helmsman config (diff) | |
| download | fs-tracer-backend-a68b8738dd91b1cd30b677df1055da0e1871dc38.tar.gz fs-tracer-backend-a68b8738dd91b1cd30b677df1055da0e1871dc38.tar.bz2 fs-tracer-backend-a68b8738dd91b1cd30b677df1055da0e1871dc38.zip | |
payload-processor: fmt
| -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 b673a15..66bac0e 100644 --- a/src/payload-processor/processor/processor.go +++ b/src/payload-processor/processor/processor.go @@ -26,7 +26,7 @@ func (p Processor) ProcessMessages() { if err != nil { break } - 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 offset %d: %s = %s\n", time.Now().String(), m.Offset, string(m.Key), string(m.Value)) } if err := p.kafka_reader.Close(); err != nil { |