Closed vladaburian closed 4 weeks ago
scanner.Bytes() returns internal buffer which is reused. That results in corrupted messages as message value (internal buffer) is modified by scanner while being sent to kafka.
scanner.Bytes()
scanner
good catch - thank you!
scanner.Bytes()
returns internal buffer which is reused. That results in corrupted messages as message value (internal buffer) is modified byscanner
while being sent to kafka.