simon

Now About plugins Never compatible with it? Example: ```go import loggerp "github.com/asim/go-micro/plugins/logger/logrus/v3" // error, type error logger.DefaultLogger = loggerp.NewLogger(loggerp.WithLogger(l)) ``` but I not found go-micro.dev/v4 plugins about v4

go get: go-micro.dev/v4/plugins/auth/[email protected]: parsing go.mod: module declares its path as: github.com/micro/go-micro but was required as: go-micro.dev/v4/plugins/auth/jwt 

has retry params

@slaunay I am just disconnecting the network during the running process.

@slaunay This is a stack of panic. ```text goroutine 58 [running]: github.com/Shopify/sarama.(*partitionProducer).newHighWatermark(0xc000218600, 0x1) vendor/github.com/Shopify/sarama/async_producer.go:618 +0x19d github.com/Shopify/sarama.(*partitionProducer).dispatch(0xc000218600) vendor/github.com/Shopify/sarama/async_producer.go:562 +0x4f7 github.com/Shopify/sarama.withRecover(0x0) vendor/github.com/Shopify/sarama/utils.go:43 +0x3e created by github.com/Shopify/sarama.(*asyncProducer).newPartitionProducer vendor/github.com/Shopify/sarama/async_producer.go:513 +0x1fb ``` This is a...

> Hi @crcms Can you please test this with #2182 ? Thank you! Already testing, still has question

@slaunay thank you very much, but the issue #2182 I used it, and it's still problematic

I have the same problem, 2G is too little for me, we need more than 8G

The partition feature of kafka doesn't support such behavior, but there is another idea to consume it and redistribute it downstream, similar to a proxy, which we are doing and...

I've had the same problem recently, I'll try to roll back to 1.5.0