-
-
Notifications
You must be signed in to change notification settings - Fork 4
All issues
Issue creation is restricted in this repository
Issues
is:issue state:open
is:issue state:open
Search results
feat(admin): expose Streams group assignor selection (KIP-1357)
adminAdmin clientAdmin clientenhancementNew feature or requestNew feature or requestkafka-4.4Required for Kafka 4.4+ complianceRequired for Kafka 4.4+ complianceprotocolKafka wire protocol changesKafka wire protocol changesStatus: Open.#3442 In thomhurst/Dekaf;feat(streams): support topology description APIs (KIP-1331)
adminAdmin clientAdmin clientenhancementNew feature or requestNew feature or requestkafka-4.4Required for Kafka 4.4+ complianceRequired for Kafka 4.4+ complianceprotocolKafka wire protocol changesKafka wire protocol changesStatus: Open.#3441 In thomhurst/Dekaf;feat(admin): support controller unregistration (KIP-1312)
adminAdmin clientAdmin clientenhancementNew feature or requestNew feature or requestkafka-4.4Required for Kafka 4.4+ complianceRequired for Kafka 4.4+ complianceprotocolKafka wire protocol changesKafka wire protocol changesStatus: Open.#3440 In thomhurst/Dekaf;test: verify complete streams-group lifecycle on Kafka 4.4
consumerConsumer clientConsumer clientintegration-testsIntegration test additionsIntegration test additionskafka-4.4Required for Kafka 4.4+ complianceRequired for Kafka 4.4+ complianceP2Medium priorityMedium prioritytestingTest coverage improvementsTest coverage improvementsStatus: Open.#2958 In thomhurst/Dekaf;protocol: implement KIP-1071 StreamsGroupHeartbeat membership path
consumerConsumer clientConsumer clientenhancementNew feature or requestNew feature or requestintegration-testsIntegration test additionsIntegration test additionskafka-4.1Required for Kafka 4.1+ complianceRequired for Kafka 4.1+ compliancekafka-4.4Required for Kafka 4.4+ complianceRequired for Kafka 4.4+ complianceP2Medium priorityMedium priorityprotocolKafka wire protocol changesKafka wire protocol changesStatus: Open.#2766 In thomhurst/Dekaf;streams: track gates for reopening a separate Dekaf.Streams runtime
apiPublic API improvementsPublic API improvementsenhancementNew feature or requestNew feature or requestP3Low priorityLow priorityperformancePerformance improvementsPerformance improvementsStatus: Open.#2748 In thomhurst/Dekaf;deps(snappy): expose reusable block codec lifecycle upstream
P3Low priorityLow priorityperformancePerformance improvementsPerformance improvementsprotocolKafka wire protocol changesKafka wire protocol changesStatus: Open.#2352 In thomhurst/Dekaf;- Status: Open.#288 In thomhurst/Dekaf;