Hi,

When using the Kafka 4.0.0 client, we could enable shared consumers by
providing the following properties in an embedded Kafka environment.

For example,

"unstable.api.versions.enable=true",
 "group.coordinator.rebalance.protocols=classic,share",
"share.coordinator.state.topic.replication.factor=1",
 "share.coordinator.state.topic.min.isr=1"

When upgrading to Kafka 4.1.0, the same tests work with just the last
two properties. Is that expected? (Basically, I don't need to set
unstable.api.versions.enable or group.coordinator.rebalance.protocols
in 4.1.0).

The documentation shows something like setting share.version to 1
using the kafka-features.sh script? I am curious why the embedded
Kafka cluster worked without going through this procedure.

I really appreciate any help you can provide.

Soby Chacko

Reply via email to