sarama icon indicating copy to clipboard operation
sarama copied to clipboard

kafka producer panic on updateBroker

Open 3AceShowHand opened this issue 1 month ago • 0 comments

Description
Versions
Sarama Kafka Go
v1.41.2
Configuration

Logs
panic: assignment to entry in nil map

goroutine 17419 [running]:
github.com/IBM/sarama.(*client).updateBroker(0x405b0fdc20, {0x4053092f40, 0x7, 0x2766c?})
	github.com/IBM/[email protected]/client.go:729 +0x2c0
github.com/IBM/sarama.(*client).updateMetadata(0x405b0fdc20, 0x40738555e0, 0x0)
	github.com/IBM/[email protected]/client.go:1098 +0xa4
github.com/IBM/sarama.(*client).tryRefreshMetadata(0x405b0fdc20, {0x405facc300, 0x1, 0x1}, 0xa, {0x48e11e0?, 0x405b0fdc01?, 0xbb70180?})
	github.com/IBM/[email protected]/client.go:1040 +0x7fc
github.com/IBM/sarama.(*client).RefreshMetadata(0x405b0fdc20, {0x405facc300, 0x1, 0x1})
	github.com/IBM/[email protected]/client.go:560 +0x110
github.com/IBM/sarama.(*client).LeaderAndEpoch(0x405b0fdc20, {0x406a928f90, 0x12}, 0x14)
	github.com/IBM/[email protected]/client.go:503 +0x94
github.com/IBM/sarama.(*client).Leader(0x403ff4a6e8?, {0x406a928f90?, 0x403e1a9200?}, 0x4efe700?)
	github.com/IBM/[email protected]/client.go:492 +0x20
github.com/IBM/sarama.(*partitionProducer).dispatch(0x4051978720)
	github.com/IBM/[email protected]/async_producer.go:632 +0x4c
github.com/IBM/sarama.withRecover(0x403ff2ea00?)
	github.com/IBM/[email protected]/utils.go:43 +0x40
created by github.com/IBM/sarama.(*asyncProducer).newPartitionProducer in goroutine 12219
	github.com/IBM/[email protected]/async_producer.go:600 +0x1a8

logs: CLICK ME


Additional Context

3AceShowHand avatar Nov 27 '25 10:11 3AceShowHand