We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c4396c1 commit 27ecfc5Copy full SHA for 27ecfc5
internal/topic/topicwriterinternal/writer_reconnector.go
@@ -66,7 +66,8 @@ type WriterReconnectorConfig struct {
66
}
67
68
func (cfg *WriterReconnectorConfig) validate() error {
69
- if cfg.defaultPartitioning.Type == rawtopicwriter.PartitioningMessageGroupID && cfg.producerID != cfg.defaultPartitioning.MessageGroupID {
+ if cfg.defaultPartitioning.Type == rawtopicwriter.PartitioningMessageGroupID &&
70
+ cfg.producerID != cfg.defaultPartitioning.MessageGroupID {
71
return xerrors.WithStackTrace(errProducerIDNotEqualMessageGroupID)
72
73
return nil
0 commit comments