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
#16176 - KAFKA-10787: Update spotless version and remove support JDK8
Pull Request -
State: open - Opened by gongxuanzhang 27 days ago
#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
#16171 - MINOR: Fix missing wait topic finished in TopicBasedRemoteLogMetadataManagerRestartTest
Pull Request -
State: closed - Opened by brandboat 28 days ago
- 1 comment
#16170 - KAFKA-16785: Migrate TopicBasedRemoteLogMetadataManagerRestartTest to new test infra
Pull Request -
State: closed - Opened by brandboat 28 days ago
#16169 - KAFKA-15156 Update cipherInformation correctly in DefaultChannelMetadataRegistry
Pull Request -
State: closed - Opened by ganesh-sadanala 29 days ago
#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
#16165 - KAFKA-16814 KRaft broker cannot startup when `partition.metadata` is missing
Pull Request -
State: open - Opened by brandboat 29 days ago
#16164 - KAFKA-16223: Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest
Pull Request -
State: closed - Opened by chiacyu 29 days ago
#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
#16162 - KAFKA-16811 Sliding window approach to calculate non-zero punctuate-ratio metric
Pull Request -
State: open - Opened by ganesh-sadanala 30 days ago
- 1 comment
#16161 - KAFKA-16858: Throw DataException from validateValue on array and map schemas without inner schemas
Pull Request -
State: open - Opened by gharris1727 30 days ago
#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
#16156 - KAFKA-15305: The background thread should try to process the remaining task until the shutdown timer is expired.
Pull Request -
State: open - Opened by frankvicky about 1 month ago
#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
#16147 - KAFKA-15045: (KIP-924 pt. 16) TaskAssignor.onAssignmentComputed handling
Pull Request -
State: open - Opened by apourchet about 1 month ago
#16145 - MINOR: Adjust validateOffsetCommit/Fetch in ConsumerGroup to ensure compatibility with classic protocol members
Pull Request -
State: open - Opened by dongnuo123 about 1 month ago
- 1 comment
Labels: KIP-848
#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
#16122 - KAFKA-16837, KAFKA-16838: Ignore task configs for deleted connectors, and compare raw task configs before publishing them
Pull Request -
State: open - Opened by C0urante about 1 month ago
- 3 comments
Labels: connect
#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
#16115 - KAFKA-16557 Implemented OffsetFetchRequestState toStringBase and added a test for it in CommitRequestManagerTest
Pull Request -
State: open - Opened by brenden20 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
#16042 - KAFKA-16807: DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions
Pull Request -
State: closed - Opened by m1a2st about 1 month ago
- 8 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
#16019 - KAFKA-16666: Migrate `TransactionLogMessageFormatter`, GroupMetadataMessageFormatter` and `OffsetsMessageFormatter`to tools module
Pull Request -
State: open - Opened by m1a2st about 1 month ago
- 1 comment
#16017 - KAFKA-16639: Ensure HeartbeatRequestManager generates leave request regardless of in-flight heartbeats.
Pull Request -
State: closed - Opened by frankvicky about 1 month ago
- 10 comments
#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
#15961 - KAFKA-16764: New consumer should throw InvalidTopicException on poll when invalid topic in metadata.
Pull Request -
State: open - Opened by appchemist about 2 months ago
- 10 comments
#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
#15675 - MINOR: migrate ReassignPartitionsIntegrationTest to use ClusterTestExtensions
Pull Request -
State: open - Opened by FrankYang0529 3 months ago
- 6 comments
#15673 - KAFKA-16480: Bump ListOffsets version, IBP version and mark last version of ListOffsets as unstable
Pull Request -
State: open - Opened by clolov 3 months ago
- 14 comments
#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
#15341 - KAFKA-14569: Migrate Kafka Streams tests from Zookeeper to KRaft
Pull Request -
State: open - Opened by mdedetrich 5 months ago
#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
#15335 - KAFKA-16234: Log directory failure re-creates partitions in another logdir automatically
Pull Request -
State: open - Opened by OmniaGM 5 months ago
- 1 comment
#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
#15332 - KAFKA-16218: Make partition reassignment completed as soon as adding replicas are in-sync
Pull Request -
State: open - Opened by drawxy 5 months ago