Your ROOT_URL in app.ini is http://git.slaventius.ru/ but you are visiting http://37.143.12.169/test3k/authDB/blame/commit/6e72707a6a00d4a4cf92b0761981d976ccb97ca0/internal/transport/kafka/balancer.go You should set ROOT_URL correctly, otherwise the web may not work correctly.

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
}