Skip to content

Pull requests: apache/kafka

New pull request New
1,115 Open 15,195 Closed
1,115 Open 15,195 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Milestones
Filter by milestone
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

KAFKA-15045: (KIP-924 pt. 25) HA Task Assignor implemented
#16315 opened Jun 12, 2024 by apourchet Loading…
3 tasks
KAFKA-15045: (KIP-924 pt. 24) Correct stateful task flagging
#16314 opened Jun 12, 2024 by apourchet Loading…
3 tasks
MINOR: update Kafka Streams docs with 3.2 KIP information docs streams
#16313 opened Jun 12, 2024 by mjsax Loading…
KAFKA-16000 Migrated MembershipManagerImplTest away from ConsumerTestBuilder
#16312 opened Jun 12, 2024 by brenden20 Loading…
3
KAFKA-16913 Support external schemas in JSONConverter
#16311 opened Jun 12, 2024 by ganesh-sadanala Loading…
2 of 3 tasks
KAFKA-16637: AsyncKafkaConsumer removes offset fetch responses from cache too aggressively
#16310 opened Jun 12, 2024 by kirktrue • Draft
3 tasks
MINOR: Simplify GroupMetadataManager#toTopicPartitions by using ConsumerProtocolSubscription instead of ConsumerPartitionAssignor.Subscription KIP-848
#16309 opened Jun 12, 2024 by dongnuo123 Loading…
3 tasks
KAFKA-15853: Move config getters and validation into server
#16307 opened Jun 12, 2024 by OmniaGM • Draft
3 tasks
MINOR: Add readiness check for connector and separate Kafka cluster in ExactlyOnceSourceIntegrationTest::testSeparateOffsetsTopic connect tests Test fixes (including flaky tests)
#16306 opened Jun 12, 2024 by C0urante Loading…
3 tasks
1
KAFKA-16942 Use ConcurrentHashMap in RecordAccumulator#nodeStats
#16305 opened Jun 12, 2024 by brandboat Loading…
3 tasks
MINOR: Improving log for outstanding requests on close and cleanup
#16304 opened Jun 12, 2024 by lianetm Loading…
7
KAFKA-16862: Refactor ConsumerTaskTest to be deterministic and avoid tight loops
#16303 opened Jun 12, 2024 by xiaoqingwanga Loading…
3 tasks
7
KAFKA-16938: non-dynamic props gets corrupted due to circular reference between DynamicBrokerConfig and DynamicConfig.
#16302 opened Jun 12, 2024 by frankvicky Loading…
3 tasks
17
KAFKA-16806: Explicitly declare JUnit dependencies for all test modules
#16301 opened Jun 12, 2024 by frankvicky • Draft
3 tasks
Kafka-16448: punctuate processing exceptions
#16300 opened Jun 12, 2024 by sebastienviale Loading…
KAFKA-10787: Apply spotless to group-coordinator and group-coordinator-api
#16298 opened Jun 12, 2024 by gongxuanzhang Loading…
1
KAFKA-10787: Apply spotless to metadata and server and storage module
#16297 opened Jun 12, 2024 by gongxuanzhang Loading…
1
KAFKA-16803: Update ShadowJavaPlugin dependencies Pull requests that update a dependency file
#16295 opened Jun 12, 2024 by Nancy-ksolves Loading…
3 tasks
2
Logging for new topic auto-creation for Producers
#16293 opened Jun 11, 2024 by jayim243 Loading…
KAFKA-16557 Implemented OffsetFetchRequestState toStringBase and added a test for it
#16291 opened Jun 11, 2024 by brenden20 Loading…
28
MINOR: Make online downgrade failure logs less noisy and update the timeouts scheduled in convertToConsumerGroup KIP-848
#16290 opened Jun 11, 2024 by dongnuo123 Loading…
3 tasks
1
KAFKA-16638 Align the naming convention for config and default variables in *Config classes
#16289 opened Jun 11, 2024 by EricLuGHub Loading…
3 tasks
KAFKA-16935: Automatically wait for cluster startup in embedded Connect integration tests connect tests Test fixes (including flaky tests)
#16288 opened Jun 11, 2024 by C0urante Loading…
3 tasks
12
KAFKA-16934: Clean up and refactor release.py
#16287 opened Jun 11, 2024 by soarez Loading…
4
MINOR: Clean up for KafkaAdminClientTest
#16285 opened Jun 11, 2024 by tinaselenge Loading…
3 tasks
1
ProTip! Filter pull requests by the default branch with base:trunk.