-
Notifications
You must be signed in to change notification settings - Fork 14.5k
Insights: apache/kafka
Overview
-
0 Active issues
-
- 40 Merged pull requests
- 27 Open pull requests
- 0 Closed issues
- 0 New issues
Could not load contribution data
Please try again later
40 Pull requests merged by 28 people
-
KAFKA-19456: State and leader epoch should not be updated on writes.
#20079 merged
Jul 1, 2025 -
KAFKA-19455: Retry persister request on metadata image issues.
#20078 merged
Jul 1, 2025 -
MINOR: Remove threadNamePrefix parameter from ReplicaManager and ReplicaFetcherManager
#20069 merged
Jul 1, 2025 -
KAFKA-19152: Add top-level documentation for OAuth flows
#20025 merged
Jul 1, 2025 -
MINOR: improve StreamsProducer error handling
#20058 merged
Jun 30, 2025 -
MINOR: remove unused FlattenedIterator
#20067 merged
Jun 30, 2025 -
KAFKA-19379: Basic upgrade guide for KIP-1071 EA
#20029 merged
Jun 30, 2025 -
KAFKA-19445: Fix coordinator runtime metrics sharing sensors
#20062 merged
Jun 30, 2025 -
MINOR: Make feature lists immutable
#20052 merged
Jun 30, 2025 -
MINOR: Fix typo in AssignmentsManager
#20059 merged
Jun 29, 2025 -
KAFKA-18486: Remove ReplicaManager#becomeLeaderOrFollower
#20037 merged
Jun 29, 2025 -
MINOR: Correct ProducerFailureHandlingTest Typo, Use waitForTopic Instead of waitForDeletion
#20054 merged
Jun 29, 2025 -
KAFKA-19042 Rewrite ConsumerBounceTest by Java
#19822 merged
Jun 29, 2025 -
MINOR: Use primitive data types in tools
#20038 merged
Jun 29, 2025 -
MINOR: Change version from 3.9.2 to 3.9.2-SNAPSHOT
#20065 merged
Jun 29, 2025 -
KAFKA-10357: Add new Kafka Streams exception classes
#19988 merged
Jun 28, 2025 -
KAFKA-19420:Don't export SocketServer from ClusterInstance
#20002 merged
Jun 27, 2025 -
KAFKA-17662: config.providers configuration missing from the docs
#18930 merged
Jun 27, 2025 -
MINOR: Cleanup hasMemberSubscriptionChanged
#20047 merged
Jun 27, 2025 -
MINOR: Improve ProcessorContext JavaDocs
#20042 merged
Jun 26, 2025 -
KAFKA-19436: Restrict cache update for ongoing batch/offset state
#20041 merged
Jun 26, 2025 -
MINOR: Add group-coordinator label for pull requests
#20043 merged
Jun 26, 2025 -
KAFKA-19246; OffsetFetch API does not return group level errors correctly with version 1
#19704 merged
Jun 26, 2025 -
MINOR: Clean up in ReassignPartitionsCommandTest
#20035 merged
Jun 26, 2025 -
MINOR: Cleanup ShareFetchAcknowledgeRequestTest
#19852 merged
Jun 26, 2025 -
KAFKA-18834: Fix LoggingResourceTest#testSetLevelDefaultScope
#19920 merged
Jun 26, 2025 -
KAFKA-19282: Update quotaTypesEnabled on quota removal in ClientQuotaManager
#19742 merged
Jun 25, 2025 -
MINOR: Fix response for consumer group describe with empty group id (#20030)
#20036 merged
Jun 25, 2025 -
KAFKA-19414: Remove 2PC public APIs from 4.1 until release (KIP-939)
#19985 merged
Jun 25, 2025 -
MINOR: Reject requests using unsupported features in KIP-1071
#20031 merged
Jun 25, 2025 -
KAFKA-18486: Migrate tests to use applyDelta instead of becomeLeaderOrFollower
#20014 merged
Jun 25, 2025 -
KAFKA-18656: Backport KAFKA-18597 to 4.0
#20026 merged
Jun 25, 2025 -
MINOR: Fix response for consumer group describe with empty group id
#20030 merged
Jun 25, 2025 -
MINOR: Remove unused DescribeTopicPartitionResponse.prepareResponse function
#20032 merged
Jun 25, 2025 -
KAFKA-19383: Handle the deleted topics when applying ClearElrRecord (…
#20034 merged
Jun 25, 2025 -
KAFKA-19383: Handle the deleted topics when applying ClearElrRecord (…
#20033 merged
Jun 25, 2025 -
KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically
#20022 merged
Jun 25, 2025 -
KAFKA-19294: Fix BrokerLifecycleManager RPC timeouts
#19745 merged
Jun 24, 2025 -
MINOR: Revert initial transactional state store semantics commit
#19956 merged
Jun 24, 2025 -
KAFKA-19383: Handle the deleted topics when applying ClearElrRecord
#19916 merged
Jun 24, 2025
27 Pull requests opened by 23 people
-
KAFKA-19272: Add initPid Response handling when keepPrepared is set to true (KIP-939)
#20039 opened
Jun 25, 2025 -
KAFKA-19427: Allow the coordinator to grow its buffer dynamically
#20040 opened
Jun 25, 2025 -
KAFKA-6333 java.awt.headless should not be on commandline
#20044 opened
Jun 26, 2025 -
KAFKA-14915: allow read remote storage for multiple partitions in one fetchRequest
#20045 opened
Jun 26, 2025 -
KAFKA-19432: Add an ERROR log message if broker.heartbeat.interval.ms is too large
#20046 opened
Jun 26, 2025 -
KAFKA-19439; OffsetFetch API does not return group level errors correctly with version 1 for 4.0
#20048 opened
Jun 26, 2025 -
KAFKA-19440: Handle top-level errors in AlterShareGroupOffsets RPC
#20049 opened
Jun 26, 2025 -
KAFKA-19439; OffsetFetch API does not return group level errors correctly with version 1 for 3.9
#20050 opened
Jun 26, 2025 -
MINOR: Move ClientQuotasRequestTest to server module
#20053 opened
Jun 27, 2025 -
KAFKA-19431: Ensure consumer and share assignment consistency with subscriptions
#20055 opened
Jun 27, 2025 -
Bug fixes for delete and state epoch.
#20056 opened
Jun 27, 2025 -
KAFKA-19443: test-common ClusterInstance should make it easy to have more listeners
#20057 opened
Jun 27, 2025 -
MINOR: simplify OpenIterator
#20060 opened
Jun 27, 2025 -
KAFKA-19441: encapsulate MetadataImage in GroupCoordinator/ShareCoordinator
#20061 opened
Jun 28, 2025 -
KAFKA-10357 Refactor makeReady to reduce complexity and support upcoming KIP-698 changes
#20063 opened
Jun 28, 2025 -
KAFKA-18105 Fix flaky PlaintextAdminIntegrationTest#testElectPreferredLeaders
#20068 opened
Jun 30, 2025 -
KAFKA-19429: Deflake streams_smoke_test, again
#20070 opened
Jun 30, 2025 -
KAFKA-19184; Add documentation for upgrading the kraft version
#20071 opened
Jun 30, 2025 -
KAFKA-19221: Backport to 4.0
#20072 opened
Jun 30, 2025 -
MINOR Enable Gradle remote caching
#20073 opened
Jun 30, 2025 -
KAFKA-19363: Finalize heterogeneous simple share assignor
#20074 opened
Jun 30, 2025 -
KAFKA-19453: Ignore group not found in share group record replay.
#20076 opened
Jul 1, 2025 -
MINOR: Cleanups in Connect
#20077 opened
Jul 1, 2025 -
KAFKA-19463: nextFetchOffset does not take ongoing state transition into account
#20080 opened
Jul 1, 2025 -
KAFKA-19042 Move PlaintextConsumerTest to client-integration-tests module
#20081 opened
Jul 1, 2025 -
KAFKA-19458: resume cleaning on future replica dir change
#20082 opened
Jul 1, 2025
67 Unresolved conversations
Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.
-
KAFKA-19397: Ensure consistent metadata usage in produce request and response
#19964 commented on
Jul 1, 2025 • 31 new comments -
KAFKA-19390: Call safeForceUnmap() in AbstractIndex.resize() on Linux to prevent stale mmap of index files
#19961 commented on
Jul 1, 2025 • 25 new comments -
KAFKA-19254: Add generic feature level metrics
#20021 commented on
Jun 30, 2025 • 21 new comments -
DRAFT KAFKA-18692: Consider to unify KStreamImpl "repartitionRequired" with GraphNode "keyChangingOperation"
#18800 commented on
Jun 29, 2025 • 16 new comments -
KAFKA-15599: Move KafkaMetadataLog to the raft module
#19762 commented on
Jun 25, 2025 • 7 new comments -
KAFKA-16717 [3/N]: Add AdminClient.alterShareGroupOffsets
#19820 commented on
Jun 26, 2025 • 7 new comments -
KAFKA-16913 - Support external schemas in JSONConverter
#19449 commented on
Jul 1, 2025 • 6 new comments -
MINOR: testDelayedTxnOffsetCommitWithBumpedEpochIsRejected
#20024 commented on
Jun 27, 2025 • 5 new comments -
MINOR: Refactor createResponseConfig to avoid collection copy and conversion
#19867 commented on
Jun 30, 2025 • 4 new comments -
KAFKA-19306: Migrate LogCompactionTester to tools module
#19905 commented on
Jun 28, 2025 • 2 new comments -
KAFKA-10357: Add explicit internal topic initialization for Kafka Streams
#19913 commented on
Jun 28, 2025 • 2 new comments -
KAFKA-19371: Don't create the __remote_log_metadata topic when it already exists during broker restarts
#19899 commented on
Jul 1, 2025 • 2 new comments -
KAFKA-19395 - Updated Junit and mockito version and license information in NOTICE-binary for Jakarta RESTful Web Services Project
#19943 commented on
Jun 25, 2025 • 2 new comments -
MINOR: Improved ConsumerRebalanceListenerInvoker for code reusage
#18202 commented on
Jul 1, 2025 • 2 new comments -
KAFKA-17259: Support to override serverProperties and restart cluster in ClusterTestExtensions
#16808 commented on
Jun 30, 2025 • 2 new comments -
MINOR: Cleanup Connect Module (1/n)
#19869 commented on
Jul 1, 2025 • 1 new comment -
KAFKA-18884: Move TransactionMetadata to transaction-coordinator module
#19699 commented on
Jul 1, 2025 • 1 new comment -
KAFKA-18185: remove internal.leave.group.on.close config
#19400 commented on
Jun 29, 2025 • 1 new comment -
(WIP) KAFKA-19261 Move ConnectionQuotas to server module
#20011 commented on
Jun 29, 2025 • 0 new comments -
KAFKA-19426: Correct the TopicBasedRemoteLogMetadataManager#initializeResources' retry default configure value to reasonable one
#20008 commented on
Jun 29, 2025 • 0 new comments -
KAFKA-18752: Fix the warning of no-operation caused by slf4j in building kafka
#19501 commented on
Jun 29, 2025 • 0 new comments -
KAFKA-18066: Fix mismatched StreamThread ID in log messages
#19517 commented on
Jun 29, 2025 • 0 new comments -
[WIP]KAFKA-18896 add KIP-877 support for Login
#19527 commented on
Jun 26, 2025 • 0 new comments -
KAFKA-19123 the buffer of forwarded request should be released after receiving the reponse from controller
#19566 commented on
Jun 28, 2025 • 0 new comments -
KAFKA-19168: MirrorMaker kafka_metrics_count metric is always incorrect
#19573 commented on
Jun 25, 2025 • 0 new comments -
KAFKA-19425: Stop the server when fail to initialize to avoid local segment never got deleted.
#20007 commented on
Jul 1, 2025 • 0 new comments -
KAFKA-19262 Add a test to verify all metrics naming pattern
#19720 commented on
Jun 28, 2025 • 0 new comments -
KAFKA-19387: Add rack awareness assignment to UniformHomogeneousAssignmentBuilder (wip)
#20000 commented on
Jun 26, 2025 • 0 new comments -
MINOR: Cleanup JMH-Benchmarks Module
#19791 commented on
Jul 1, 2025 • 0 new comments -
KAFKA-19415 Shuffle the order of readPartitionInfo when fetching data.
#19990 commented on
Jun 26, 2025 • 0 new comments -
KAFKA-19305 Ensure all image classes are immutable
#19847 commented on
Jun 26, 2025 • 0 new comments -
KAFKA-19276: Trigger rebalance for streams config update [WIP]
#19967 commented on
Jun 28, 2025 • 0 new comments -
KAFKA-18193 Refactor Kafka Streams CloseOptions to Fluent API Style
#19955 commented on
Jun 28, 2025 • 0 new comments -
KAFKA-19357: AsyncConsumer#close hangs during closing because the commitAsync request never completes due to a missing coordinator
#19914 commented on
Jul 1, 2025 • 0 new comments -
KAFKA-19381: add ConfigDef.ConfigKey.Builder
#19912 commented on
Jun 26, 2025 • 0 new comments -
MINOR: Write log differently according to the size of missingListenerPartitions
#11418 commented on
Jun 26, 2025 • 0 new comments -
MINOR: migrate SaslClientsWithInvalidCredentialsTest to use ClusterTestExtensions
#16225 commented on
Jun 26, 2025 • 0 new comments -
KAFKA-16959: ConfigCommand should allow to define both `entity-default` and `entity-name`
#16381 commented on
Jun 26, 2025 • 0 new comments -
Kafka-16355: Fix ConcurrentModificationException in evictWhile Method
#16554 commented on
Jun 27, 2025 • 0 new comments -
KAFKA-17645: KIP-1052: Enable warmup in producer performance test
#17340 commented on
Jun 27, 2025 • 0 new comments -
KAFKA-17834 Improvement the Dockerfile
#17554 commented on
Jun 26, 2025 • 0 new comments -
KAFKA-17601: Inter-broker connections do not expose their clientSoftwareName and clientSoftwareVersion tags
#17731 commented on
Jun 27, 2025 • 0 new comments -
KAFKA-17821: the set of configs displayed by `logAll` could be invalid
#17993 commented on
Jun 26, 2025 • 0 new comments -
KAFKA-10730: KafkaApis#handleProduceRequest should use auto-generated protocol
#18216 commented on
Jun 30, 2025 • 0 new comments -
KAFKA-17554: Flaky testFutureCompletionOutsidePoll in ConsumerNetworkClientTest
#18298 commented on
Jun 28, 2025 • 0 new comments -
KAFKA-18351 remove `version` tag for docker-compose.yml
#18322 commented on
Jun 26, 2025 • 0 new comments -
KAFKA-18356 Explicitly setting up instrumentation for inline mocking (Java 21+)
#18339 commented on
Jun 26, 2025 • 0 new comments -
KAFKA-18149: Docs improvement for dynamic kraft quorum
#18350 commented on
Jun 26, 2025 • 0 new comments -
KAFKA-18600 Cleanup NetworkClient zk related logging
#18644 commented on
Jun 26, 2025 • 0 new comments -
KAFKA-16653: Remove delayed initialization because of static voter set
#18885 commented on
Jun 30, 2025 • 0 new comments -
MINOR: Enable auth test for new consumer
#18947 commented on
Jun 30, 2025 • 0 new comments -
KAFKA-18842: add configurable max number of connectors
#18993 commented on
Jun 25, 2025 • 0 new comments -
KAFKA-17651: Implement `describeUserScramCredentials`
#19066 commented on
Jun 29, 2025 • 0 new comments -
KAFKA-18607: Update jfreechart dependency
#19074 commented on
Jun 28, 2025 • 0 new comments -
KAFKA-18982: Allow ClusterTests to ignore specific thread leaks
#19206 commented on
Jul 1, 2025 • 0 new comments -
KAFKA-18679: KafkaRaftMetrics metrics are exposing doubles instead of integers
#19220 commented on
Jun 27, 2025 • 0 new comments -
[WIP]KAFKA-19000 Flaky test report should use absolute time for links
#19228 commented on
Jun 28, 2025 • 0 new comments -
[WIP] KAFKA-18877: Add an mechanism to find cases where we accessed variables from the wrong thread.
#19231 commented on
Jun 26, 2025 • 0 new comments -
KAFKA-17573: Move KRaftMetadataCache to metadata module
#19232 commented on
Jun 30, 2025 • 0 new comments -
KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch
#19236 commented on
Jul 1, 2025 • 0 new comments -
KAFKA-6333 java.awt.headless should not be on commandline
#19237 commented on
Jun 27, 2025 • 0 new comments -
KAFKA-19008 Remove scala version from artifacts
#19241 commented on
Jun 28, 2025 • 0 new comments -
MINOR: Add doc for configuration parameters to keep the format consistent
#19244 commented on
Jun 27, 2025 • 0 new comments -
MINOR: Specify 2.1 as the minimum broker version for clients
#19250 commented on
Jul 1, 2025 • 0 new comments -
修复docker jvm构建错误(Fix Docker JVM build errors)
#19267 commented on
Jul 1, 2025 • 0 new comments -
KAFKA-18913: Removing _state.updater.enabled_ flag through the Stream…
#19275 commented on
Jun 30, 2025 • 0 new comments -
KAFKA-18563: move RaftClientTestContext RpcVersion methods into RaftProtocol
#19349 commented on
Jun 26, 2025 • 0 new comments