Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / apache/kafka issues and pull requests

#16178 - KAFKA-15852: Move LinuxIoMetricsCollector to server module

Pull Request - State: open - Opened by mimaison 27 days ago

#16177 - MINOR: Use project path instead of name for spotlessApplyModules in Gradle script

Pull Request - State: open - Opened by C0urante 27 days ago - 2 comments
Labels: tools

#16175 - KAFKA-16881: InitialState type leaks into the Connect REST API OpenAPI spec

Pull Request - State: open - Opened by m1a2st 27 days ago
Labels: docs, connect

#16174 - MINOR: Small refactor in TargetAssignmentBuilder

Pull Request - State: open - Opened by dajac 27 days ago
Labels: KIP-848

#16173 - KAFKA-16880 : Update equals and hashcode methods for two attributes

Pull Request - State: open - Opened by muralibasani 27 days ago - 3 comments

#16172 - KAFKA-10787: Apply spotless to transaction-coordinator and server-common

Pull Request - State: open - Opened by gongxuanzhang 28 days ago - 5 comments

#16168 - KAFKA-16698 : Add timeout to alterClientQuotas

Pull Request - State: open - Opened by muralibasani 29 days ago - 1 comment

#16167 - [Draft] KAFKA-16689: Move LogValidatorTest to storage module

Pull Request - State: open - Opened by TaiJuWu 29 days ago

#16166 - Minor: Add URL to log for Connect RestClient

Pull Request - State: closed - Opened by farbodahm 29 days ago - 1 comment

#16163 - KAFKA-16861: Don't convert to group to classic if the size is larger than group max size.

Pull Request - State: open - Opened by frankvicky 29 days ago - 14 comments
Labels: KIP-848

#16160 - KAFKA-16252: Dynamic KRaft network manager and channel

Pull Request - State: open - Opened by ahuang98 30 days ago - 1 comment

#16159 - SMT InsertField current timestamp

Pull Request - State: open - Opened by andreit-geomotiv 30 days ago

#16158 - KAFKA-14509: [4/4] Handle includeAuthorizedOperations

Pull Request - State: open - Opened by riedelmax 30 days ago - 2 comments
Labels: KIP-848

#16157 - KAFKA-15718: Refactor UncleanLeaderElectionTest to enable KRaft later

Pull Request - State: open - Opened by tinaselenge about 1 month ago
Labels: tests

#16155 - MINOR: reduce the test suits of consumer group tools

Pull Request - State: closed - Opened by m1a2st about 1 month ago - 2 comments
Labels: tests

#16154 - KAFKA-16852 : Adding two thread pools to Remote Log Manager

Pull Request - State: closed - Opened by muralibasani about 1 month ago
Labels: tiered-storage

#16153 - KAFKA-16859: Cleanup check if tiered storage is enabled

Pull Request - State: closed - Opened by m1a2st about 1 month ago - 6 comments
Labels: tiered-storage

#16152 - KAFKA-16866: Used the right constant in RLMT#testFetchQuotaManagerConfig

Pull Request - State: closed - Opened by kamalcph about 1 month ago - 1 comment

#16151 - KAFKA-16047: Use REQUEST_TIMEOUT_MS_CONFIG in AdminClient.fenceProducers

Pull Request - State: open - Opened by edoardocomar about 1 month ago
Labels: admin

#16150 - MINOR: Bump trunk to 3.9.0-SNAPSHOT

Pull Request - State: closed - Opened by jlprat about 1 month ago - 3 comments

#16149 - KAFKA-16860; [2/2] Introduce group.version feature flag

Pull Request - State: closed - Opened by dajac about 1 month ago
Labels: KIP-848

#16148 - MINOR: update all-latency-avg documentation

Pull Request - State: closed - Opened by sebastienviale about 1 month ago - 3 comments
Labels: streams, docs

#16144 - KAFKA-16664: Re-add EventAccumulator.poll(long, TimeUnit)

Pull Request - State: open - Opened by jeffkbkim about 1 month ago
Labels: KIP-848

#16140 - KAFKA-16001 Migrated ConsumerNetworkThreadTest away from ConsumerTestBuilder

Pull Request - State: open - Opened by brenden20 about 1 month ago - 1 comment
Labels: tests

#16138 - KAFKA-16856 : Adding new exception

Pull Request - State: open - Opened by muralibasani about 1 month ago - 2 comments
Labels: tiered-storage

#16134 - KAFKA-16715: Create KafkaShareConsumer interfaces

Pull Request - State: open - Opened by AndrewJSchofield about 1 month ago - 3 comments
Labels: queues-for-kafka

#16133 - MINOR: Refactor DynamicConfig

Pull Request - State: closed - Opened by mimaison about 1 month ago

#16132 - KAFKA-16851: Add remote.log.disable.policy

Pull Request - State: open - Opened by clolov about 1 month ago - 2 comments
Labels: tiered-storage

#16131 - KAFKA-16854: Add StopReplica v5

Pull Request - State: open - Opened by clolov about 1 month ago - 6 comments
Labels: tiered-storage

#16127 - [Draft]Topic command integration test migrate to new test infra

Pull Request - State: open - Opened by TaiJuWu about 1 month ago
Labels: tests

#16126 - KAFKA-16223: Migrate KafkaConfigBackingStoreTest to Mockito

Pull Request - State: open - Opened by johnnychhsu about 1 month ago - 1 comment
Labels: connect, tests

#16124 - KAFKA-16558 Implemented HeartbeatRequestState toStringBase() and added a test for it

Pull Request - State: open - Opened by brenden20 about 1 month ago - 3 comments

#16120 - KAFKA-16860; [1/2] Introduce group.version feature flag

Pull Request - State: closed - Opened by dajac about 1 month ago - 10 comments
Labels: KIP-848

#16118 - KAFKA-16583: Handle PartitionChangeRecord without directory IDs

Pull Request - State: open - Opened by soarez about 1 month ago - 2 comments

#16116 - KAFKA-15853: Move configDef out of core

Pull Request - State: open - Opened by OmniaGM about 1 month ago - 3 comments

#16106 - KAFKA-16520 KIP-853 Changes to DescribeQuorum request/response

Pull Request - State: open - Opened by nizhikov about 1 month ago - 4 comments

#16105 - KAFKA-16483: Remove preAppendErrors from createPutCacheCallback

Pull Request - State: open - Opened by FrankYang0529 about 1 month ago

#16097 - KAFKA-10787: Add import ordering checkstyle rule and configure an automatic formatter

Pull Request - State: closed - Opened by gongxuanzhang about 1 month ago - 2 comments

#16096 - bumping shadowJar 8.1.0->8.1.1

Pull Request - State: closed - Opened by EricLuGHub about 1 month ago - 5 comments

#16088 - KAFKA-16864; Optimize uniform (homogenous) assignor

Pull Request - State: closed - Opened by dajac about 1 month ago - 7 comments
Labels: KIP-848

#16080 - KAFKA-15630 Improve documentation of offset.lag.max

Pull Request - State: open - Opened by ganesh-sadanala about 1 month ago
Labels: docs, mirror-maker-2

#16070 - MINOR: mention KAFKA-15905 in docs "Notable changes in 3.7.1"

Pull Request - State: closed - Opened by edoardocomar about 1 month ago - 5 comments

#16068 - KAFKA-16821: Member Subscription Spec Interface

Pull Request - State: open - Opened by rreddy-22 about 1 month ago - 2 comments
Labels: KIP-848

#16058 - KAFKA-16535: Implement AddVoter, RemoveVoter, UpdateVoter RPCs

Pull Request - State: open - Opened by cmccabe about 1 month ago - 1 comment
Labels: kraft, KIP-853

#16053 - KAFKA-9228: Restart tasks on runtime-only connector config changes

Pull Request - State: open - Opened by C0urante about 1 month ago - 1 comment
Labels: connect

#16049 - [MINOR] Code Cleanup (Clients Module)

Pull Request - State: open - Opened by sjhajharia about 1 month ago - 3 comments

#16031 - KAFKA-16200: Enforce that RequestManager implementations respect user-provided timeout

Pull Request - State: open - Opened by kirktrue about 1 month ago - 4 comments

#16025 - KAFKA-16809: Run Javadoc in CI

Pull Request - State: closed - Opened by gharris1727 about 1 month ago

#16022 - KAFKA-16713: Define initial set of RPCs for KIP-932

Pull Request - State: closed - Opened by AndrewJSchofield about 1 month ago - 5 comments
Labels: queues-for-kafka

#16013 - MINOR: Optimize heartbeat to broker in test

Pull Request - State: open - Opened by TaiJuWu about 1 month ago - 1 comment

#15993 - KAFKA-16541 Fix potential leader-epoch checkpoint file corruption

Pull Request - State: open - Opened by ocadaruma about 1 month ago - 3 comments

#15989 - KAFKA-16223: Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest

Pull Request - State: closed - Opened by chiacyu about 1 month ago - 1 comment

#15986 - KAFKA-16525; Dynamic KRaft network manager and channel

Pull Request - State: open - Opened by jsancio about 1 month ago - 3 comments
Labels: kraft, KIP-853

#15945 - KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2

Pull Request - State: closed - Opened by cmccabe about 2 months ago - 2 comments

#15914 - MINOR: Upgrade scala-logging to 3.9.5

Pull Request - State: closed - Opened by viktorsomogyi about 2 months ago - 4 comments

#15910 - KAFKA-15905 Restarts of MirrorCheckpointTask should not permanently i…

Pull Request - State: closed - Opened by edoardocomar about 2 months ago - 20 comments
Labels: mirror-maker-2

#15908 - MINOR: migrate DescribeConsumerGroupTest to use ClusterTestExtensions

Pull Request - State: open - Opened by FrankYang0529 about 2 months ago - 7 comments

#15876 - KIP-966 unclean recovery elect leader request

Pull Request - State: open - Opened by mannoopj about 2 months ago

#15863 - KAFKA-16574: The metrics of LogCleaner disappear after reconfiguration

Pull Request - State: closed - Opened by chiacyu about 2 months ago - 2 comments

#15862 - KAFKA-16652: add unit test for ClusterTemplate offering zero ClusterConfig

Pull Request - State: closed - Opened by TaiJuWu about 2 months ago - 3 comments

#15857 - KAFKA-16027: MINOR Refactor MetadataTest#testUpdatePartitionLeadership (2)

Pull Request - State: open - Opened by Alexander-Aghili about 2 months ago - 3 comments

#15834 - KAFKA-16606 Gate JBOD configuration on 3.7-IV2

Pull Request - State: open - Opened by soarez 2 months ago - 5 comments

#15830 - KAFKA-15713: KRaft support in AclCommandTest

Pull Request - State: open - Opened by pasharik 2 months ago - 4 comments

#15826 - [WIP] KAFKA-16553: Add config logging for controller

Pull Request - State: open - Opened by johnnychhsu 2 months ago

#15821 - MINOR: migrate ListConsumerGroupTest to use ClusterTestExtensions

Pull Request - State: closed - Opened by FrankYang0529 2 months ago - 6 comments

#15820 - KAFKA-15265: Integrate RLMQuotaManager for throttling copies to remote storage

Pull Request - State: open - Opened by abhijeetk88 2 months ago - 1 comment
Labels: tiered-storage

#15790 - KAFKA-16573: Specify node and store where serdes are needed

Pull Request - State: open - Opened by AyoubOm 2 months ago - 3 comments
Labels: streams

#15556 - KAFKA-16383: fix flaky IdentityReplicationIntegrationTest .testReplicateFromLatest

Pull Request - State: open - Opened by johnnychhsu 3 months ago - 5 comments
Labels: tests, mirror-maker-2

#15344 - MINOR: fix scala 2.12 compilation

Pull Request - State: open - Opened by cmccabe 5 months ago

#15343 - MINOR fix scala compile issue

Pull Request - State: open - Opened by mumrah 5 months ago - 1 comment

#15342 - MINOR: ZKAcl Migration Client Test Problem failing in Scala version 2.12

Pull Request - State: open - Opened by highluck 5 months ago - 1 comment

#15340 - MINOR: EventAccumulator should signal to one thread when key becomes available

Pull Request - State: open - Opened by dajac 5 months ago
Labels: KIP-848

#15339 - KAFKA-16116: Rebalance Metrics for AsyncKafkaConsumer

Pull Request - State: open - Opened by philipnee 5 months ago - 1 comment

#15338 - KAFKA-16237: Add Scala 3 support for Kafka Streams

Pull Request - State: open - Opened by mberndt123 5 months ago - 1 comment
Labels: streams

#15337 - Global state store restore custom processor

Pull Request - State: open - Opened by wcarlson5 5 months ago

#15336 - [No review] Repro kafka-16217

Pull Request - State: open - Opened by CalvinConfluent 5 months ago

#15334 - KAFKA-16155: Re-enable testAutoCommitIntercept

Pull Request - State: open - Opened by lucasbru 5 months ago

#15333 - Added ACLs authorizer change during migration

Pull Request - State: open - Opened by ppatierno 5 months ago - 2 comments