Hi, Are there any limitations to testing the new queue feature in 4.0.0 with a cluster generated via KafkaClusterTestKit? I am passing all the necessary properties to the test cluster.
unstable.api.versions.enable=true group.coordinator.rebalance.protocols=classic,consumer,share And other share.coordinator.* properties for a single node cluster. However, I am not able to consume anything in a test via the share consumer. The share consumer works when I switch this to a local real cluster. Is there any gap in the KafkaClusterTestKit for the early-access queue feature introduced via KIP-932? Thank you, Soby Chacko.
