14 lines
378 B
14 lines
378 B
2 years ago
|
package kafka
|
||
|
|
|
||
|
|
import "github.com/segmentio/kafka-go"
|
||
|
|
|
||
|
|
// Собственный балансировщик для определения номера партиции
|
||
|
|
// в которую попадет очередное сообщение
|
||
|
|
type MyBalancer struct {
|
||
|
|
Cool bool
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *MyBalancer) Balance(msg kafka.Message, partitions ...int) (partition int) {
|
||
|
|
return 0
|
||
|
|
}
|