Messages by Date
-
2024/05/14
Re: [PR] KAFKA-15905 Restarts of MirrorCheckpointTask should not permanently i… [kafka]
via GitHub
-
2024/05/14
[jira] [Commented] (KAFKA-16664) Re-add EventAccumulator.take(timeout)
Quoc Phong Dang (Jira)
-
2024/05/14
Re: [PR] KAFKA-16709: abortAndPauseCleaning only when future log is not existed [kafka]
via GitHub
-
2024/05/14
[PR] KAFKA-16709: abortAndPauseCleaning only when future log is not existed [kafka]
via GitHub
-
2024/05/14
Re: [PR] MINOR: Migrate tests in o.a.k.streams to JUnit 5 (except KafkaStreamsTest) [kafka]
via GitHub
-
2024/05/14
Re: [PR] MINOR: Migrate tests in o.a.k.streams to JUnit 5 (except KafkaStreamsTest) [kafka]
via GitHub
-
2024/05/14
Re: [PR] MINOR: Migrate tests in o.a.k.streams to JUnit 5 (except KafkaStreamsTest) [kafka]
via GitHub
-
2024/05/14
Re: [PR] MINOR: Migrate tests in o.a.k.streams to JUnit 5 (except KafkaStreamsTest) [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/14
[jira] [Commented] (KAFKA-16758) Extend Consumer#close with option to leave the group or not
David Jacot (Jira)
-
2024/05/14
[jira] [Updated] (KAFKA-16760) alterReplicaLogDirs failed even if responded with none error
Luke Chen (Jira)
-
2024/05/14
[jira] [Commented] (KAFKA-16760) alterReplicaLogDirs failed even if responded with none error
Luke Chen (Jira)
-
2024/05/14
[jira] [Created] (KAFKA-16760) alterReplicaLogDirs failed even if responded with none error
Luke Chen (Jira)
-
2024/05/14
[jira] [Created] (KAFKA-16759) Invalid client telemetry transition on consumer close
Andrew Schofield (Jira)
-
2024/05/14
Re: [PR] MINOR: Various cleanups in clients tests [kafka]
via GitHub
-
2024/05/14
Re: [PR] MINOR: Various cleanups in clients tests [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-15170: CooperativeStickyAssignor may fail adjust assignment [kafka]
via GitHub
-
2024/05/14
Re: [PR] MINOR: Add coverage for MM2 heartbeats topic detection [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-15170: CooperativeStickyAssignor may fail adjust assignment [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-15170: CooperativeStickyAssignor may fail adjust assignment [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-15170: CooperativeStickyAssignor may fail adjust assignment [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-15170: CooperativeStickyAssignor may fail adjust assignment [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-15170: CooperativeStickyAssignor may fail adjust assignment [kafka]
via GitHub
-
2024/05/14
[PR] MINOR: Fix TargetAssignmentBuilderBenchmark [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-15170: CooperativeStickyAssignor may fail adjust assignment [kafka]
via GitHub
-
2024/05/14
[PR] MINOR: Rename `Record` to `CoordinatorRecord` [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-15170: CooperativeStickyAssignor may fail adjust assignment [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-16702: Fix producer leaks in KafkaLog4jAppenderTest [kafka]
via GitHub
-
2024/05/14
[jira] [Resolved] (KAFKA-16694) Remove rack aware code in assignors temporarily due to performance
David Jacot (Jira)
-
2024/05/14
Re: [PR] KAFKA-16694: Remove Rack Awareness Code from the Server Side Assignors [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-16738: Returns BaseRecords instead of MemoryRecords [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-16738: Returns BaseRecords instead of MemoryRecords [kafka]
via GitHub
-
2024/05/14
Re: [PR] MINOR: Move `group-coordinator` import control to its own file [kafka]
via GitHub
-
2024/05/14
Re: [PR] KAFKA-15170: CooperativeStickyAssignor may fail adjust assignment [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16574: The metrics of LogCleaner disappear after reconfiguration [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16703: Close serverChannel in SocketServer if unable to bind to a port [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16702: Fix producer leaks in KafkaLog4jAppenderTest [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15170: CooperativeStickyAssignor may fail adjust assignment [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16702: Fix producer leaks in KafkaLog4jAppenderTest [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16702: Fix producer leaks in KafkaLog4jAppenderTest [kafka]
via GitHub
-
2024/05/13
[jira] [Commented] (KAFKA-16758) Extend Consumer#close with option to leave the group or not
A. Sophie Blee-Goldman (Jira)
-
2024/05/13
Re: [PR] MINOR: fix LogValidatorTest#checkNonCompressed [kafka]
via GitHub
-
2024/05/13
Re: [PR] MINOR: revisit LogValidatorTest#checkRecompression [kafka]
via GitHub
-
2024/05/13
[PR] MINOR: revisit LogValidatorTest#checkRecompression [kafka]
via GitHub
-
2024/05/13
[jira] [Commented] (KAFKA-16514) Kafka Streams: stream.close(CloseOptions) does not respect options.leaveGroup flag.
A. Sophie Blee-Goldman (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16758) Extend Consumer#close with option to leave the group or not
A. Sophie Blee-Goldman (Jira)
-
2024/05/13
Re: [PR] KAFKA-16514: backdoor for modifying internal leave.group.on.close config [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16514: backdoor for modifying internal leave.group.on.close config [kafka]
via GitHub
-
2024/05/13
[PR] KAFKA-16711: make sure update highestOffsetInRemoteStorage after log dir change [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15170: CooperativeStickyAssignor may fail adjust assignment [kafka]
via GitHub
-
2024/05/13
[jira] [Comment Edited] (KAFKA-16361) Rack aware sticky assignor minQuota violations
li xiangyuan (Jira)
-
2024/05/13
[jira] [Comment Edited] (KAFKA-16361) Rack aware sticky assignor minQuota violations
li xiangyuan (Jira)
-
2024/05/13
[jira] [Comment Edited] (KAFKA-16361) Rack aware sticky assignor minQuota violations
li xiangyuan (Jira)
-
2024/05/13
[jira] [Commented] (KAFKA-16361) Rack aware sticky assignor minQuota violations
li xiangyuan (Jira)
-
2024/05/13
[jira] [Commented] (KAFKA-16361) Rack aware sticky assignor minQuota violations
li xiangyuan (Jira)
-
2024/05/13
[PR] KAFKA-16705 the flag "started" of RaftClusterInstance is false even though the cluster is started [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16705 the flag "started" of RaftClusterInstance is false even though the cluster is starte [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/13
Re: [PR] Add demo template for transactional client [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16695: Improve expired poll logging [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16695: Improve expired poll logging [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka]
via GitHub
-
2024/05/13
Re: [PR] KIP-966 unclean recovery elect leader request [kafka]
via GitHub
-
2024/05/13
Re: [PR] KIP-966 unclean recovery elect leader request [kafka]
via GitHub
-
2024/05/13
Re: [PR] KIP-966 unclean recovery elect leader request [kafka]
via GitHub
-
2024/05/13
Re: [PR] KIP-966 unclean recovery elect leader request [kafka]
via GitHub
-
2024/05/13
Re: [PR] KIP-966 unclean recovery elect leader request [kafka]
via GitHub
-
2024/05/13
Re: [PR] KIP-966 unclean recovery elect leader request [kafka]
via GitHub
-
2024/05/13
Re: [PR] KIP-966 unclean recovery elect leader request [kafka]
via GitHub
-
2024/05/13
Re: [PR] KIP-966 unclean recovery elect leader request [kafka]
via GitHub
-
2024/05/13
Re: [PR] KIP-966 unclean recovery elect leader request [kafka]
via GitHub
-
2024/05/13
Re: [PR] KIP-966 unclean recovery elect leader request [kafka]
via GitHub
-
2024/05/13
Re: [PR] KIP-966 unclean recovery elect leader request [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16577: New consumer fails with stop within allotted timeout in consumer_test.py system test [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16577: New consumer fails with stop within allotted timeout in consumer_test.py system test [kafka]
via GitHub
-
2024/05/13
[PR] KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2 [kafka]
via GitHub
-
2024/05/13
[jira] [Created] (KAFKA-16757) Fix broker re-registration issues around MV 3.7-IV2
Colin McCabe (Jira)
-
2024/05/13
Re: [PR] KAFKA-16452: Don't throw OOORE when converting the offset to metadata [kafka]
via GitHub
-
2024/05/13
[jira] [Commented] (KAFKA-16687) Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0
Philip Nee (Jira)
-
2024/05/13
Re: [PR] KAFKA-16526; Quorum state data version 1 [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16526; Quorum state data version 1 [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16526; Quorum state data version 1 [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16526; Quorum state data version 1 [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16526; Quorum state data version 1 [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16526; Quorum state data version 1 [kafka]
via GitHub
-
2024/05/13
Re: [PR] MINOR: fix LogValidatorTest#checkNonCompressed [kafka]
via GitHub
-
2024/05/13
[jira] [Commented] (KAFKA-16603) Data loss when kafka connect sending data to Kafka
Anil Dasari (Jira)
-
2024/05/13
[jira] [Commented] (KAFKA-16603) Data loss when kafka connect sending data to Kafka
Anil Dasari (Jira)
-
2024/05/13
Re: [PR] KAFKA-15045: (KIP-924 pt. 2) Implement ApplicationState and KafkaStreamsState [kafka]
via GitHub
-
2024/05/13
[jira] [Commented] (KAFKA-16361) Rack aware sticky assignor minQuota violations
A. Sophie Blee-Goldman (Jira)
-
2024/05/13
[PR] KAFKA-15045: (KIP-924 pt. 3) Implement KafkaStreamsAssignment [kafka]
via GitHub
-
2024/05/13
[jira] [Assigned] (KAFKA-10369) Introduce Distinct operation in KStream
Ayoub Omari (Jira)
-
2024/05/13
Re: [PR] Adds the correct specific paths to codeartifact [kafka]
via GitHub
-
2024/05/13
[PR] Adds the correct specific paths to codeartifact [kafka]
via GitHub
-
2024/05/13
[PR] MINOR: Migrate tests in o.a.k.streams to JUnit 5 (except KafkaStreamsTest) [kafka]
via GitHub
-
2024/05/13
[jira] [Commented] (KAFKA-16700) Kafka Streams: possible message loss on KTable-KTable FK Left Join
Jira
-
2024/05/13
Re: [PR] MINOR: Change sys test describe topic parsing to improve extensibility [kafka]
via GitHub
-
2024/05/13
[PR] MINOR: Change sys test describe topic parsing to improve extensibility [kafka]
via GitHub
-
2024/05/13
[jira] [Updated] (KAFKA-16687) Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0
Philip Nee (Jira)
-
2024/05/13
[jira] [Comment Edited] (KAFKA-16687) Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0
Philip Nee (Jira)
-
2024/05/13
[jira] [Commented] (KAFKA-16687) Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0
Philip Nee (Jira)
-
2024/05/13
Re: [PR] MINOR: fix LogValidatorTest#checkNonCompressed [kafka]
via GitHub
-
2024/05/13
Re: [PR] MINOR: fix LogValidatorTest#checkNonCompressed [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16637: AsyncKafkaConsumer removes offset fetch responses from cache too aggressively [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16637: AsyncKafkaConsumer removes offset fetch responses from cache too aggressively [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16577: New consumer fails with stop within allotted timeout in consumer_test.py system test [kafka]
via GitHub
-
2024/05/13
[jira] [Resolved] (KAFKA-15578) Run System Tests for Old protocol in the New Coordinator
David Jacot (Jira)
-
2024/05/13
[jira] [Assigned] (KAFKA-14701) More broker side partition assignor to common
David Jacot (Jira)
-
2024/05/13
Re: [PR] KAFKA-16739: Exclude protected members from aggregated release Javadocs [kafka]
via GitHub
-
2024/05/13
[PR] KAFKA-16739: Exclude protected members from aggregated release Javadocs [kafka]
via GitHub
-
2024/05/13
[jira] [Resolved] (KAFKA-16117) Add Integration test for checking if the correct assignor is chosen
David Jacot (Jira)
-
2024/05/13
Re: [PR] KAFKA-14509: [3/4] Add integration test for consumerGroupDescribe Api [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-14509: [3/4] Add integration test for consumerGroupDescribe Api [kafka]
via GitHub
-
2024/05/13
[jira] [Resolved] (KAFKA-16735) Deprecate offsets.commit.required.acks in 3.8
David Jacot (Jira)
-
2024/05/13
Re: [PR] KAFKA-16735; Deprecate offsets.commit.required.acks [kafka]
via GitHub
-
2024/05/13
[jira] [Updated] (KAFKA-16737) Clean up KafkaConsumerTest TODOs enabling tests for new consumer
Kirk True (Jira)
-
2024/05/13
Re: [PR] KAFKA-16452: Don't throw OOORE when converting the offset to metadata [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16452: Don't throw OOORE when converting the offset to metadata [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15307: update/note deprecated configs [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16452: Don't throw OOORE when converting the offset to metadata [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16735; Deprecate offsets.commit.required.acks [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16452: Don't throw OOORE when converting the offset to metadata [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16452: Don't throw OOORE when converting the offset to metadata [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16452: Don't throw OOORE when converting the offset to metadata [kafka]
via GitHub
-
2024/05/13
[jira] [Commented] (KAFKA-16692) InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when upgrading from kafka 3.5 to 3.6
Justine Olshan (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16756) Implement max delivery count functionality in SharePartition
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16753) Implement acknowledge functionality in SharePartition
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16755) Implement lock timeout functionality in SharePartition
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16754) Implement release acquired records functionality in SharePartition
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16752) Implement acquire functionality in SharePartition
Apoorv Mittal (Jira)
-
2024/05/13
Re: [PR] KAFKA-16452: Don't throw OOORE when converting the offset to metadata [kafka]
via GitHub
-
2024/05/13
[jira] [Created] (KAFKA-16750) Implement acknowledge API in SharePartitionManager
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16751) Implement release acquired records in SharePartitionManager
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16749) Implement share fetch messages
Apoorv Mittal (Jira)
-
2024/05/13
Re: [PR] KAFKA-16452: Don't throw OOORE when converting the offset to metadata [kafka]
via GitHub
-
2024/05/13
[jira] [Created] (KAFKA-16747) Implement share sessions and context
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16748) Implement share response handling in SharePartitionManager
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Assigned] (KAFKA-16743) Add support for share group heartbeat in KafkaApis
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16746) Add support for share acknowledgement request in KafkaApis
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16745) Add support for share fetch request in KafkaApis
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16744) Add support for share group describe in KafkaApis
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16743) Add support for share group heartbeat in KafkaApis
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16741) Add SharGroupHeartbeat API support in GroupCoordinator
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16742) Add ShareGroupDescribe API support in GroupCoordinator
Apoorv Mittal (Jira)
-
2024/05/13
Re: [PR] KAFKA-16735; Deprecate offsets.commit.required.acks [kafka]
via GitHub
-
2024/05/13
[jira] [Created] (KAFKA-16740) Define skeleton for SharePartitionManager and SharePartition
Apoorv Mittal (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16739) Exclude protected variables from aggregated JavaDocs
Greg Harris (Jira)
-
2024/05/13
Re: [PR] KAFKA-16264: Expose `producer.id.expiration.check.interval.ms` as dynamic broker configuration [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16702: Fix producer leaks in KafkaLog4jAppenderTest [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16686: Wait for given offset in TopicBasedRemoteLogMetadataManagerTest [kafka]
via GitHub
-
2024/05/13
Re: [PR] MINOR: fix flaky testRecordThreadIdleRatioTwoThreads test [kafka]
via GitHub
-
2024/05/13
[jira] [Commented] (KAFKA-16245) DescribeConsumerGroupTest failing
Andrew Schofield (Jira)
-
2024/05/13
Re: [PR] FIX 16705 the flag "started" of RaftClusterInstance is false even though the cluster is started [kafka]
via GitHub
-
2024/05/13
[PR] FIX 16705 the flag "started" of RaftClusterInstance is false even though the cluster is started [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16526; Quorum state data version 1 [kafka]
via GitHub
-
2024/05/13
Re: [PR] MINOR: Add classic member session timeout to ClassicMemberMetadata [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16738: Returns BaseRecords instead of MemoryRecords [kafka]
via GitHub
-
2024/05/13
Re: [PR] fix KAFKA-16705:the flag "started" of RaftClusterInstance is false even though the cluster is started [kafka]
via GitHub
-
2024/05/13
[PR] fix KAFKA-16705:the flag "started" of RaftClusterInstance is false even though the cluster is started [kafka]
via GitHub
-
2024/05/13
[PR] MINOR: add logging for testRecordThreadIdleRatioTwoThreads [kafka]
via GitHub
-
2024/05/13
Re: [PR] fix KAFKA-16705:the flag "started" of RaftClusterInstance is false even though the cluster is started [kafka]
via GitHub
-
2024/05/13
Re: [PR] fix KAFKA-16705:the flag "started" of RaftClusterInstance is false even though the cluster is started [kafka]
via GitHub
-
2024/05/13
Re: [PR] MINOR: Add classic member session timeout to ClassicMemberMetadata [kafka]
via GitHub
-
2024/05/13
Re: [PR] MINOR: Refactor Values class to fix checkstyle, add benchmark, optimize exceptions [kafka]
via GitHub
-
2024/05/13
Re: [PR] MINOR: Refactor Values class to fix checkstyle, add benchmark, optimize exceptions [kafka]
via GitHub
-
2024/05/13
Re: [PR] MINOR: Refactor Values class to fix checkstyle, add benchmark, optimize exceptions [kafka]
via GitHub
-
2024/05/13
Re: [PR] MINOR: Refactor Values class to fix checkstyle, add benchmark, optimize exceptions [kafka]
via GitHub
-
2024/05/13
Re: [PR] MINOR: Refactor Values class to fix checkstyle, add benchmark, optimize exceptions [kafka]
via GitHub
-
2024/05/13
Re: [PR] MINOR: Refactor Values class to fix checkstyle, add benchmark, optimize exceptions [kafka]
via GitHub
-
2024/05/13
[PR] MINOR: Use ClusterTemplate in ApiVersionsRequestTest [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16598 Mirgrate `ResetConsumerGroupOffsetTest` to new test infra [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-15045: (KIP-924 pt. 2) Implement ApplicationState and KafkaStreamsState [kafka]
via GitHub
-
2024/05/13
[jira] [Updated] (KAFKA-16738) Returns BaseRecords instead of MemoryRecords
Zhenyu Luo (Jira)
-
2024/05/13
[jira] [Assigned] (KAFKA-16737) Clean up KafkaConsumerTest TODOs enabling tests for new consumer
Lianet Magrans (Jira)
-
2024/05/13
[PR] KAFKA-16738: Returns BaseRecords instead of MemoryRecords [kafka]
via GitHub
-
2024/05/13
[jira] [Updated] (KAFKA-16737) Clean up KafkaConsumerTest TODOs enabling tests for new consumer
Lianet Magrans (Jira)
-
2024/05/13
[jira] [Updated] (KAFKA-16737) Clean up KafkaConsumerTest TODOs enabling tests for new consumer
Lianet Magrans (Jira)
-
2024/05/13
[jira] [Updated] (KAFKA-16737) Clean up KafkaConsumerTest TODOs enabling tests for new consumer
Lianet Magrans (Jira)
-
2024/05/13
[jira] [Created] (KAFKA-16738) Returns BaseRecords instead of MemoryRecords
Zhenyu Luo (Jira)
-
2024/05/13
Re: [PR] KAFKA-14588 [3/N] ConfigCommandTest rewritten in java [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-7632: Support Compression Levels (KIP-390) [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-7632: Support Compression Levels (KIP-390) [kafka]
via GitHub
-
2024/05/13
[jira] [Updated] (KAFKA-16693) Kafka Users are created with ACL entries and during performing operations allowed by ACL we see Denied Operation
Janardhana Gopalachar (Jira)
-
2024/05/13
Re: [PR] MINOR: Various cleanups in clients tests [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16629: Add broker-related tests to ConfigCommandIntegrationTest [kafka]
via GitHub
-
2024/05/13
Re: [PR] KAFKA-16629: Add broker-related tests to ConfigCommandIntegrationTest [kafka]
via GitHub
-
2024/05/13
[PR] MINOR: Move `group-coordinator` import control to its own file [kafka]
via GitHub
-
2024/05/13
[PR] KAFKA-16223: Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest [kafka]
via GitHub
-
2024/05/13
[PR] MINOR: Add coverage for MM2 heartbeats topic detection [kafka]
via GitHub
-
2024/05/13
[jira] [Commented] (KAFKA-16700) Kafka Streams: possible message loss on KTable-KTable FK Left Join
Ayoub Omari (Jira)