NewTopicConfig makes a configuration which defaults to 32 partitions for every topic.
()
| 72 | |
| 73 | // NewTopicConfig makes a configuration which defaults to 32 partitions for every topic. |
| 74 | func NewTopicConfig() *TopicConfig { |
| 75 | return &TopicConfig{ |
| 76 | overridePartitions: make(map[string]int32, 0), |
| 77 | defaultPartitions: 32, |
| 78 | } |
| 79 | } |
| 80 | |
| 81 | // SetDefaultPartitions sets the number of partitions any topic not explicitly configured otherwise |
| 82 | // (by SetPartitions) will have from the perspective of created partitioners. |
no outgoing calls
no test coverage detected