jira@kafka.apache.org, 2024-05

You are viewing a plain text version of this content. The canonical link for it is here.

- Re: [PR] KAFKA-15713: KRaft support in AclCommandTest [kafka] - posted by "pasharik (via GitHub)" <gi...@apache.org> on 2024/05/01 00:02:51 UTC, 16 replies.
- [jira] [Commented] (KAFKA-16637) KIP-848 does not work well - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/01 00:57:00 UTC, 2 replies.
- Re: [PR] KAFKA-16207; KRaft's internal log listener to update voter set [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2024/05/01 02:59:00 UTC, 33 replies.
- Re: [PR] KAFKA-16572: allow defining number of disks per broker in ClusterTest [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/01 03:00:13 UTC, 5 replies.
- [jira] [Commented] (KAFKA-16027) Refactor MetadataTest#testUpdatePartitionLeadership - posted by "Johnny Hsu (Jira)" <ji...@apache.org> on 2024/05/01 03:25:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16223) Replace EasyMock and PowerMock with Mockito for KafkaConfigBackingStoreTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/01 03:52:00 UTC, 4 replies.
- Re: [PR] KAFKA-16608: Honour interrupted thread state on KafkaConsumer.poll [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2024/05/01 03:57:14 UTC, 4 replies.
- [jira] [Commented] (KAFKA-16650) add integration test for Admin#abortTransaction - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2024/05/01 04:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16650) add integration test for Admin#abortTransaction - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/01 04:43:00 UTC, 0 replies.
- Re: [PR] KIP-759 Mark as Partitioned [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/05/01 05:03:15 UTC, 0 replies.
- Re: [PR] KAFKA-16394: Fix null propagation in foreign key join result [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/05/01 05:28:10 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-16644) FK join emits duplicate tombstone on left-side delete - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/01 05:29:00 UTC, 0 replies.
- Re: [PR] KAFKA-16649: Remove lock from DynamicBrokerConfig.removeReconfigurable [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/01 05:49:12 UTC, 8 replies.
- Re: [PR] MINOR: Replaced Utils.join() with JDK API. [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/01 05:52:44 UTC, 6 replies.
- [jira] [Updated] (KAFKA-16651) KafkaProducer.send does not throw TimeoutException as documented - posted by "Mike Pedersen (Jira)" <ji...@apache.org> on 2024/05/01 08:19:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16651) KafkaProducer.send does not throw TimeoutException as documented - posted by "Mike Pedersen (Jira)" <ji...@apache.org> on 2024/05/01 08:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16651) KafkaProducer.send does not throw TimeoutException as documented - posted by "Haruki Okada (Jira)" <ji...@apache.org> on 2024/05/01 08:25:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16651) KafkaProducer.send does not throw TimeoutException as documented - posted by "Mike Pedersen (Jira)" <ji...@apache.org> on 2024/05/01 08:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16372) max.block.ms behavior inconsistency with javadoc and the config description - posted by "Mike Pedersen (Jira)" <ji...@apache.org> on 2024/05/01 08:35:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16652) add unit test for - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/01 08:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16652) add unit test for ClusterTemplate offering zero ClusterConfig - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/01 08:59:00 UTC, 0 replies.
- Re: [PR] KAFKA-16614:Disallow @ClusterTemplate("") [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/01 09:00:34 UTC, 4 replies.
- Re: [PR] KAFKA-16588: broker shutdown hangs when log.segment.delete.delay.ms is zero [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/01 09:11:22 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16588) broker shutdown hangs when `log.segment.delete.delay.ms` is zero - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/01 09:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16606) JBOD support in KRaft does not seem to be gated by the metadata version - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/05/01 09:31:00 UTC, 0 replies.
- Re: [PR] Allowing WriteTxnMarkers API to run with AlterCluster permissions [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/05/01 09:44:18 UTC, 12 replies.
- Re: [PR] KAFKA-9401: Reduce contention for Fetch requests [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/05/01 09:47:51 UTC, 24 replies.
- Re: [PR] KAFKA-14588 UserScramCredentialsCommandTest rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/05/01 10:03:35 UTC, 9 replies.
- [PR] KAFKA-14588 ConfigCommandTest rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/05/01 10:49:57 UTC, 3 replies.
- [PR] KAFKA-16629: Add broker-related tests to ConfigCommandIntegrationTest [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2024/05/01 13:31:49 UTC, 41 replies.
- Re: [PR] KAFKA-16647: Remove setMetadataDirectory from BrokerNode/ControllerNode [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/01 13:34:27 UTC, 2 replies.
- Re: [PR] John confluent unclean recovery elect leader request desired leaders [kafka] - posted by "chiacyu (via GitHub)" <gi...@apache.org> on 2024/05/01 13:37:36 UTC, 0 replies.
- Re: [PR] KAFKA-16593: Rewrite DeleteConsumerGroupsTest by ClusterTestExtensions [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2024/05/01 14:14:26 UTC, 28 replies.
- Re: [PR] KAFKA-16539 Fix IncrementalAlterConfigs during ZK migration [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/05/01 14:20:41 UTC, 10 replies.
- Re: [PR] KAFKA-16587: Add subscription model information to group state [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/05/01 15:25:09 UTC, 17 replies.
- [jira] [Updated] (KAFKA-15561) Client support for new SubscriptionPattern based subscription - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/01 16:26:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16272) Update connect_distributed_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/01 16:27:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16652) add unit test for ClusterTemplate offering zero ClusterConfig - posted by "TaiJuWu (Jira)" <ji...@apache.org> on 2024/05/01 16:37:00 UTC, 0 replies.
- Re: [PR] KAFKA-15974: Enforce that event processing respects user-provided timeout [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/05/01 16:46:33 UTC, 87 replies.
- Re: [PR] KAFKA-15309: Add custom error handler to Producer [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2024/05/01 16:52:37 UTC, 0 replies.
- [PR] KAFKA-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest (2/3) [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2024/05/01 17:07:35 UTC, 3 replies.
- [PR] [WIP] KAFKA-16027: refactor MetadataTest [kafka] - posted by "johnnychhsu (via GitHub)" <gi...@apache.org> on 2024/05/01 17:10:57 UTC, 0 replies.
- Re: [PR] KAFKA-16027: MINOR Refactor MetadataTest#testUpdatePartitionLeadership [kafka] - posted by "Alexander-Aghili (via GitHub)" <gi...@apache.org> on 2024/05/01 17:33:39 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16022) AsyncKafkaConsumer sometimes complains “No current assignment for partition {}” - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/01 17:59:00 UTC, 0 replies.
- Re: [PR] KAFKA-13328, KAFKA-13329 (2): Add custom preflight validation support for connector header, key, and value converters [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/05/01 18:11:03 UTC, 8 replies.
- [jira] [Commented] (KAFKA-16514) Kafka Streams: stream.close(CloseOptions) does not respect options.leaveGroup flag. - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/01 20:00:00 UTC, 3 replies.
- Re: [PR] KAFKA-16452: Don't throw OOORE when converting the offset to metadata [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2024/05/01 21:14:32 UTC, 74 replies.
- Re: [PR] KAFKA-16452: Bound high-watermark offset to range between LLSO and LEO [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2024/05/01 21:17:42 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16541) Potential leader epoch checkpoint file corruption on OS crash - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2024/05/01 21:20:00 UTC, 2 replies.
- Re: [PR] KAFKA-16480: Bump ListOffsets version, IBP version and mark last version of ListOffsets as unstable [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2024/05/01 21:30:27 UTC, 21 replies.
- Re: [PR] KAFKA-16624: Don't generate useless PartitionChangeRecord on older MV [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/05/01 21:44:26 UTC, 2 replies.
- [jira] [Created] (KAFKA-16653) Remove delayed initialization because of static voter set - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/01 21:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14620) Add a type for SnapshotId - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/01 22:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16654) Refactor kafka.test.annotation.Type and ClusterTestExtensions - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/01 23:02:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16614) Disallow `@ClusterTemplate("")` - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/01 23:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16654) Refactor kafka.test.annotation.Type and ClusterTestExtensions - posted by "TaiJuWu (Jira)" <ji...@apache.org> on 2024/05/02 00:00:00 UTC, 0 replies.
- Re: [PR] KAFKA-15307: update/note deprecated configs [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/05/02 00:31:59 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-16654) Refactor kafka.test.annotation.Type and ClusterTestExtensions - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 00:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16647) Remove setMetadataDirectory from BrokerNode/ControllerNode - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 01:05:00 UTC, 0 replies.
- [PR] KAFKA-16427: KafkaConsumer#position() does not respect timeout when group protocol is CONSUMER [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/05/02 01:15:25 UTC, 8 replies.
- [jira] [Commented] (KAFKA-16427) KafkaConsumer#position() does not respect timeout when group protocol is CONSUMER - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/02 01:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16637) KIP-848 does not work well - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/02 01:21:00 UTC, 0 replies.
- [PR] KAFKA-16637: KIP-848 does not work well [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/05/02 01:23:22 UTC, 1 replies.
- [jira] [Created] (KAFKA-16655) deflake ZKMigrationIntegrationTest.testDualWrite - posted by "Alyssa Huang (Jira)" <ji...@apache.org> on 2024/05/02 01:36:00 UTC, 0 replies.
- [PR] KAFKA-16655 Deflaking ZKMigrationIntegrationTest.testDualWrite [kafka] - posted by "ahuang98 (via GitHub)" <gi...@apache.org> on 2024/05/02 01:42:46 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16655) deflake ZKMigrationIntegrationTest.testDualWrite - posted by "Alyssa Huang (Jira)" <ji...@apache.org> on 2024/05/02 01:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15561) Client support for new SubscriptionPattern based subscription - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/05/02 02:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16260) Deprecate window.size.ms in StreamsConfig - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/02 03:07:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16260) Deprecate window.size.ms and inner.serde.class in StreamsConfig - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/02 03:07:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16260) Deprecate window.size.ms and window.inner.serde.class in StreamsConfig - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/02 03:08:00 UTC, 3 replies.
- Re: [PR] KAFKA-15951: MissingSourceTopicException should include topic names [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/05/02 03:32:14 UTC, 8 replies.
- Re: [PR] DO NOT MERGE: Isolate Connect tests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/02 03:33:06 UTC, 0 replies.
- Re: [PR] KAFKA-13152: Kip 770 buffer size fix [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/05/02 03:41:02 UTC, 0 replies.
- Re: [PR] KAFKA-16573: Specify node and store where serdes are needed [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/05/02 03:52:21 UTC, 18 replies.
- Re: [PR] KAFKA-16511: Fix the leaking tiered segments during segment deletion [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/05/02 04:25:59 UTC, 11 replies.
- Re: [PR] KAFKA-16399: Add JBOD support in tiered storage [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/05/02 06:57:28 UTC, 26 replies.
- [jira] [Commented] (KAFKA-16320) CreateTopics, DeleteTopics and CreatePartitions differences between Zookeeper and KRaft - posted by "Emanuele Sabellico (Jira)" <ji...@apache.org> on 2024/05/02 07:48:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16320) CreateTopics, DeleteTopics and CreatePartitions differences between Zookeeper and KRaft - posted by "Emanuele Sabellico (Jira)" <ji...@apache.org> on 2024/05/02 07:49:00 UTC, 1 replies.
- Re: [PR] KAFKA-16393 read/write sequence of buffers correctly [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/02 09:03:40 UTC, 7 replies.
- Re: [PR] KAFKA-13036 Replace EasyMock and PowerMock with Mockito for RocksDBMetricsRecorderTest [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/02 09:10:40 UTC, 1 replies.
- Re: [PR] KAFKA-10859: Add test annotation to FileStreamSourceTaskTest.testInvalidFile and speed up the test [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/02 09:11:14 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7014) Guarantee the byte buffer returned by Serializer is reusable - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 09:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6992) Configuring the batch.size to zero won't disable the batching entirely - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 09:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-10696) Replace ProduceResponse.PartitionResponse by auto-generated PartitionProduceResponse - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 09:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-10822) Force some stdout from system tests for Travis - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 09:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14874) Unable to create > 5000 topics for once when using Kraft - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 09:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-10291) fix flaky tools/log4j_appender_test.py - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 09:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-10288) fix flaky client/client_compatibility_features_test.py - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 09:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-10805) More useful reporting from travis system tests - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 09:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-10290) fix flaky core/compatibility_test_new_broker_test.py - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 09:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-10804) Tune travis system tests to avoid timeouts - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 09:26:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-10809) Make all system tests stably run on either Travis CI or local - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 09:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16656) Using a custom replication.policy.separator with DefaultReplicationPolicy - posted by "Lenin Joseph (Jira)" <ji...@apache.org> on 2024/05/02 09:28:00 UTC, 0 replies.
- Re: [PR] KAFKA-16615: JoinGroup API for upgrading ConsumerGroup [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/02 09:29:11 UTC, 10 replies.
- Re: [PR] KAFKA-16307: fix coordinator thread idle ratio [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/02 09:36:17 UTC, 11 replies.
- Re: [PR] KAFKA-14509: [3/4] Add integration test for consumerGroupDescribe Api [kafka] - posted by "riedelmax (via GitHub)" <gi...@apache.org> on 2024/05/02 10:45:41 UTC, 11 replies.
- [PR] KAFKA-15309: part 1-Add custom error handler for RecordTooLargeException to Producer [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2024/05/02 10:48:39 UTC, 0 replies.
- [jira] [Created] (KAFKA-16657) KIP-848 does not work well on Zookeeper Mode - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2024/05/02 11:23:00 UTC, 0 replies.
- Re: [PR] KAFKA-16027: refactor MetadataTest [kafka] - posted by "johnnychhsu (via GitHub)" <gi...@apache.org> on 2024/05/02 11:58:06 UTC, 1 replies.
- [PR] MINOR: ConsumerGroup#getOrMaybeCreateMember should not add the member to the group [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/02 12:32:17 UTC, 7 replies.
- Re: [PR] KAFKA-15062: Adding ppc64le build stage [kafka] - posted by "Vaibhav-Nazare (via GitHub)" <gi...@apache.org> on 2024/05/02 12:35:34 UTC, 1 replies.
- [jira] [Created] (KAFKA-16658) Drop `offsets.commit.required.acks` config in 4.0 (deprecate in 3.8) - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/02 13:19:00 UTC, 0 replies.
- Re: [PR] KAFKA-15897: fix ControllerRegistrationManagerTest [kafka] - posted by "johnnychhsu (via GitHub)" <gi...@apache.org> on 2024/05/02 14:14:04 UTC, 0 replies.
- Re: [PR] KAFKA-16445: Add PATCH method for connector config [kafka] - posted by "ivanyu (via GitHub)" <gi...@apache.org> on 2024/05/02 14:16:51 UTC, 23 replies.
- Re: [PR] KAFKA-16655: Deflaking ZKMigrationIntegrationTest.testDualWrite [kafka] - posted by "johnnychhsu (via GitHub)" <gi...@apache.org> on 2024/05/02 14:46:24 UTC, 5 replies.
- Re: [PR] KAFKA-16470; kafka-dump-log --offsets-decoder should support new records [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/02 15:18:27 UTC, 7 replies.
- [PR] KAFKA-14588 Tests for ConfigCommand of DynamicBrokerReconfigurationTest rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/05/02 15:37:51 UTC, 4 replies.
- Re: [PR] KAFKA-16433: BeginningAndEndOffsets and OffsetsForTimes should send an event and return empty with zero timeout provided [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2024/05/02 16:18:15 UTC, 0 replies.
- [PR] KAFKA-10199: Accept only one task per exception in queue for failed tasks [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/02 19:12:32 UTC, 2 replies.
- Re: [PR] KAFKA-15615: Improve handling of fetching during metadata updates [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/05/02 19:20:27 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16637) AsyncKafkaConsumer removes offset fetch responses from cache too aggressively - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/02 19:25:00 UTC, 0 replies.
- Re: [PR] KAFKA-16637: AsyncKafkaConsumer removes offset fetch responses from cache too aggressively [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/05/02 19:26:30 UTC, 10 replies.
- Re: [PR] KAFKA-16577: New consumer fails with stop within allotted timeout in consumer_test.py system test [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/05/02 21:03:42 UTC, 4 replies.
- [jira] [Created] (KAFKA-16659) KafkaConsumer#position() does not respect wakup when group protocol is CONSUMER - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/02 21:41:00 UTC, 0 replies.
- Re: [PR] KAFKA-7632: Support Compression Levels (KIP-390) [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2024/05/02 22:38:17 UTC, 24 replies.
- [jira] [Commented] (KAFKA-16659) KafkaConsumer#position() does not respect wakup when group protocol is CONSUMER - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2024/05/03 00:49:00 UTC, 0 replies.
- Re: [PR] KAFKA-14405: Log a warning when users attempt to set a config controlled by Streams [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/05/03 01:19:57 UTC, 7 replies.
- Re: [PR] KAFKA-16124 Add metricss.verbosity config [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/03 03:33:13 UTC, 0 replies.
- Re: [PR] KAFKA-15992 Make MM2 heartbeats topic name configurable [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/03 03:33:16 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16659) KafkaConsumer#position() does not respect wakup when group protocol is CONSUMER - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/03 03:41:00 UTC, 0 replies.
- [PR] [1/N] ConfigCommandTest rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/05/03 03:52:51 UTC, 12 replies.
- [jira] [Commented] (KAFKA-16657) KIP-848 does not work well on Zookeeper Mode - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/03 03:56:00 UTC, 5 replies.
- [PR] MINOR: log newly created processId [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/05/03 06:04:46 UTC, 1 replies.
- Re: [PR] KAFKA-16197: Print Connect worker specific logs on poll timeout expiry [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2024/05/03 06:12:11 UTC, 14 replies.
- Re: [PR] KAFKA-16484: Support to define per broker/controller property by ClusterConfigProperty [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/03 06:25:49 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-16572) allow defining number of disks per broker in ClusterTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/03 06:26:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16660) reduce the check interval to speedup DelegationTokenRequestsTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/03 07:43:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16660) reduce the check interval to speedup DelegationTokenRequestsTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/03 07:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16660) reduce the check interval to speedup DelegationTokenRequestsTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/03 07:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16661) add a lower `log.initial.task.delay.ms` value to integration test framework - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/03 07:55:00 UTC, 0 replies.
- Re: [PR] KAFKA-15018: Failing offset flush for EOS when secondary offset store writes fails for tombstone records [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2024/05/03 08:40:14 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16174) Flaky test: testDescribeQuorumStatusSuccessful – org.apache.kafka.tools.MetadataQuorumCommandTest - posted by "Johnny Hsu (Jira)" <ji...@apache.org> on 2024/05/03 08:55:00 UTC, 1 replies.
- Re: [PR] KAFKA-14401: Fail kafka log read end requests if underneath work thread is dead [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2024/05/03 09:21:32 UTC, 2 replies.
- Re: [PR] KAFKA-15265: Add Remote Log Manager quota manager [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/05/03 09:24:48 UTC, 22 replies.
- [jira] [Commented] (KAFKA-16660) reduce the check interval to speedup DelegationTokenRequestsTest - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2024/05/03 09:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16511) Leaking tiered segments - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/03 10:02:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-16662) UnwritableMetadataException: Metadata has been lost - posted by "Tobias Bohn (Jira)" <ji...@apache.org> on 2024/05/03 10:45:00 UTC, 0 replies.
- [PR] KAFKA-10199: Add remove operation with future to state updater [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/03 11:09:59 UTC, 11 replies.
- [jira] [Assigned] (KAFKA-16661) add a lower `log.initial.task.delay.ms` value to integration test framework - posted by "Chia Chuan Yu (Jira)" <ji...@apache.org> on 2024/05/03 11:40:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16174) Flaky test: testDescribeQuorumStatusSuccessful – org.apache.kafka.tools.MetadataQuorumCommandTest - posted by "Johnny Hsu (Jira)" <ji...@apache.org> on 2024/05/03 12:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16595) Introduce ClusterTemplate in ClusterTests - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2024/05/03 12:31:00 UTC, 0 replies.
- [PR] KAFKA-16659: KafkaConsumer#position() does not respect wakup when group protocol is CONSUMER [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/03 12:32:25 UTC, 6 replies.
- [jira] [Created] (KAFKA-16663) CoordinatorRuntime write timer tasks should be cancelled once HWM advances - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/05/03 13:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14579) Move DumpLogSegments to tools - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/03 14:05:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-16663) CoordinatorRuntime write timer tasks should be cancelled once HWM advances - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/05/03 14:09:00 UTC, 0 replies.
- Re: [PR] KAFKA-15756: [3/3] Migrate testConsumptionWithBrokerFailures to run old protocol in new coordinator [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/05/03 14:51:54 UTC, 0 replies.
- [jira] [Created] (KAFKA-16664) Re-add EventAccumulator.take(timeout) - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/05/03 15:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16665) Fail to get partition's position from within onPartitionsAssigned callback in new consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/03 15:29:00 UTC, 0 replies.
- [PR] MINOR: Remove `ConsumerGroupPartitionMetadataValue.Epoch` field [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/03 15:38:16 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16511) Leaking tiered segments - posted by "Francois Visconte (Jira)" <ji...@apache.org> on 2024/05/03 15:40:00 UTC, 0 replies.
- Re: [PR] KAFKA-16507 Add raw record into RecordDeserialisationException [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2024/05/03 15:50:15 UTC, 11 replies.
- [PR] KAFKA-15309: part 2-Add custom error handler for UnknownTopicOrPartitionException to Producer [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2024/05/03 15:56:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16665) Fail to get partition's position from within onPartitionsAssigned callback in new consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/03 16:10:00 UTC, 0 replies.
- [PR] KAFKA-16665: Allow to initialize newly assigned partition's positions without allowing fetching while callback runs [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/05/03 16:24:07 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-16474) AsyncKafkaConsumer might send out heartbeat request without waiting for its response - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/03 18:21:00 UTC, 0 replies.
- Re: [PR] KAFKA-14995: Automate asf.yaml collaborators refresh [kafka] - posted by "stevenbooke (via GitHub)" <gi...@apache.org> on 2024/05/03 18:43:24 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16474) AsyncKafkaConsumer might send out heartbeat request without waiting for its response - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/03 19:05:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-16474) AsyncKafkaConsumer might send out heartbeat request without waiting for its response - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/03 19:53:00 UTC, 0 replies.
- [PR] KAFKA-16027: MINOR Refactor MetadataTest#testUpdatePartitionLeadership (2) [kafka] - posted by "Alexander-Aghili (via GitHub)" <gi...@apache.org> on 2024/05/04 00:15:45 UTC, 2 replies.
- Re: [PR] Window not honored? Why is X record not dropped? [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/04 03:33:02 UTC, 1 replies.
- Re: [PR] KAFKA-15723: KRaft support in ListOffsetsRequestTest [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/04 03:33:08 UTC, 6 replies.
- [jira] [Created] (KAFKA-16666) Remove unused class `GroupMetadataMessageFormatter` and `OffsetsMessageFormatter` - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/04 04:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16666) Migrate `TransactionLogMessageFormatter`, GroupMetadataMessageFormatter` and `OffsetsMessageFormatter`to tools module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/04 05:47:00 UTC, 4 replies.
- Re: [PR] Kafka-14748: Relax non-null FK left-join requirement [kafka] - posted by "florin-akermann (via GitHub)" <gi...@apache.org> on 2024/05/04 07:39:40 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16174) Flaky test: testDescribeQuorumStatusSuccessful – org.apache.kafka.tools.MetadataQuorumCommandTest - posted by "Johnny Hsu (Jira)" <ji...@apache.org> on 2024/05/04 08:22:00 UTC, 0 replies.
- Re: [PR] KAFKA-12317: fix documentation [kafka] - posted by "florin-akermann (via GitHub)" <gi...@apache.org> on 2024/05/04 08:27:42 UTC, 0 replies.
- [PR] MINOR: remove redundant check in KafkaClusterTestKit [kafka] - posted by "johnnychhsu (via GitHub)" <gi...@apache.org> on 2024/05/04 10:15:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-14579) Move DumpLogSegments to tools - posted by "Johnny Hsu (Jira)" <ji...@apache.org> on 2024/05/04 10:37:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16667) KRaftMigrationDriver gets stuck after successive failovers - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/05/04 18:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16667) KRaftMigrationDriver gets stuck after successive failovers - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/05/04 18:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16667) KRaftMigrationDriver gets stuck after successive failovers - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/05/04 18:03:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16668) Enable to set tags by `ClusterTest` - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/04 18:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16668) Enable to set tags by `ClusterTest` - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/04 18:06:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16668) Enable to set tags by `ClusterTest` - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/04 18:36:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16624) Don't generate useless PartitionChangeRecord on older MV - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/05/04 20:26:00 UTC, 0 replies.
- [PR] KAFKA-16526; Quorum state data version 1 [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2024/05/04 20:49:18 UTC, 32 replies.
- Re: [PR] KAFKA-16526; Add quorum state v1 [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2024/05/04 20:49:55 UTC, 0 replies.
- [PR] KAFKA-16617 [kafka] - posted by "Owen-CH-Leung (via GitHub)" <gi...@apache.org> on 2024/05/05 02:57:25 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16617) Add KRaft info for the `advertised.listeners` doc description - posted by "Owen C.H. Leung (Jira)" <ji...@apache.org> on 2024/05/05 03:10:00 UTC, 0 replies.
- Re: [PR] KAFKA-15739: KRaft support in ResetConsumerGroupOffsetTest [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/05 03:33:12 UTC, 5 replies.
- Re: [PR] KAFKA-14785: Connect offset read REST API [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/05 05:30:03 UTC, 1 replies.
- [PR] [WIP] Kafka-16668: improve cluster test [kafka] - posted by "johnnychhsu (via GitHub)" <gi...@apache.org> on 2024/05/05 07:49:41 UTC, 1 replies.
- [PR] KAFKA-16652: add unit test for ClusterTemplate offering zero ClusterConfig [kafka] - posted by "TaiJuWu (via GitHub)" <gi...@apache.org> on 2024/05/05 08:40:51 UTC, 13 replies.
- [PR] KAFKA-16574: The metrics of LogCleaner disappear after reconfiguration [kafka] - posted by "chiacyu (via GitHub)" <gi...@apache.org> on 2024/05/05 09:48:12 UTC, 23 replies.
- Re: [PR] Kafka-16668: improve cluster test [kafka] - posted by "johnnychhsu (via GitHub)" <gi...@apache.org> on 2024/05/05 09:51:37 UTC, 12 replies.
- [PR] Wall-Clock based Windowing / Suppression [kafka] - posted by "eichingertim (via GitHub)" <gi...@apache.org> on 2024/05/05 10:23:32 UTC, 0 replies.
- [PR] MINOR: Remove deprecated constructors from Connect's Kafka*BackingStore classes [kafka] - posted by "yashmayya (via GitHub)" <gi...@apache.org> on 2024/05/05 13:36:12 UTC, 5 replies.
- [jira] [Created] (KAFKA-16669) Remove extra collection copy when genrating DescribeAclsResource - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/05 13:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16669) Remove extra collection copy when genrating DescribeAclsResource - posted by "Chia Chuan Yu (Jira)" <ji...@apache.org> on 2024/05/05 14:30:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16669) Remove extra collection copy when genrating DescribeAclsResource - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/05 14:31:00 UTC, 0 replies.
- Re: [PR] KAFKA-14517: Implement regex subscriptions [kafka] - posted by "JimmyWang6 (via GitHub)" <gi...@apache.org> on 2024/05/05 17:27:12 UTC, 3 replies.
- [PR] MINOR: Update upgrade documentation for 3.7.1 [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2024/05/05 20:59:38 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-16659) KafkaConsumer#position() does not respect wakup when group protocol is CONSUMER - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/06 00:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16670) KIP-848 : Consumer will not receive assignment forever because of concurrent issue. - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2024/05/06 02:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16670) KIP-848 : Consumer will not receive assignment forever because of concurrent issue. - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2024/05/06 02:17:00 UTC, 4 replies.
- Re: [PR] KAFKA-15722: KRaft support in RackAwareAutoTopicCreationTest [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/06 03:33:01 UTC, 0 replies.
- Re: [PR] KAFKA-15524, KAFKA-15917: Wait for zombie sink tasks' consumers to commit offsets before trying to modify their offsets in integration tests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/06 03:33:03 UTC, 0 replies.
- Re: [PR] KAFKA-15845: Detect leaked Kafka clients and servers with LeakTestingExtension [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/06 03:33:18 UTC, 0 replies.
- [PR] KAFKA-10199: Remove lost tasks in state updater with new remove [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/06 07:03:12 UTC, 13 replies.
- [jira] [Created] (KAFKA-16671) Revisit SessionedProtocolIntegrationTest.ensureInternalEndpointIsSecured - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/06 07:24:00 UTC, 0 replies.
- [PR] MINOR: enable test for ensureInternalEndpointIsSecured [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/06 07:28:24 UTC, 6 replies.
- [jira] [Created] (KAFKA-16672) Fix flaky DedicatedMirrorIntegrationTest.testMultiNodeCluster - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/06 08:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16672) Fix flaky DedicatedMirrorIntegrationTest.testMultiNodeCluster - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/06 08:10:00 UTC, 0 replies.
- [PR] added logic to avoid unneeded subscription regex check [kafka] - posted by "Phuc-Hong-Tran (via GitHub)" <gi...@apache.org> on 2024/05/06 08:50:17 UTC, 0 replies.
- [PR] KAFKA-10199: Revoke tasks from state updater with new remove [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/06 09:46:57 UTC, 4 replies.
- [PR] MINOR: use classic consumer with ZK mode for DeleteOffsetsConsumerGroupCommandIntegrationTest [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/06 10:44:00 UTC, 6 replies.
- Re: [PR] KAFKA-8721: Kafka metrics improvements [kafka] - posted by "jsto (via GitHub)" <gi...@apache.org> on 2024/05/06 10:52:54 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16393) SslTransportLayer doesn't implement write(ByteBuffer[], int, int) correctly - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/06 11:12:00 UTC, 0 replies.
- [PR] KAFKA-14588 [2/N] ConfigCommandTest rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/05/06 11:33:35 UTC, 12 replies.
- [PR] MINOR: Remove dev_version parameter from streams tests [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/05/06 12:49:23 UTC, 5 replies.
- [PR] MINOR: Correct connector scheduled rebalance logs [kafka] - posted by "yuz10 (via GitHub)" <gi...@apache.org> on 2024/05/06 13:06:25 UTC, 3 replies.
- [PR] John confluent unclean recovery elect leader request [kafka] - posted by "mannoopj (via GitHub)" <gi...@apache.org> on 2024/05/06 13:20:57 UTC, 2 replies.
- [jira] [Created] (KAFKA-16673) Optimize toTopicPartitions with ConsumerProtocolSubscription - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/05/06 14:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16674) Adjust classicGroupJoinToConsumerGroup to add subscription model - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/05/06 14:21:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16674) Adjust classicGroupJoinToConsumerGroup to add subscription model - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/05/06 14:22:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16673) Optimize toTopicPartitions with ConsumerProtocolSubscription - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/05/06 14:22:00 UTC, 0 replies.
- Re: [PR] [KAFKA-16646] Don't run cve scan job on forks [kafka] - posted by "omkreddy (via GitHub)" <gi...@apache.org> on 2024/05/06 14:46:09 UTC, 0 replies.
- [PR] MINOR: Various cleanups in clients tests [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/06 14:49:45 UTC, 20 replies.
- [jira] [Created] (KAFKA-16675) Move rebalance callback test for positions to callbacks test file - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/06 15:35:00 UTC, 0 replies.
- Re: [PR] KAFKA-15804: Close SocketServer channels when calling shutdown before enableRequestProcessing [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/06 15:42:48 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16619) Unnecessary controller warning : "Loaded ZK migration state of NONE" - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/05/06 16:15:00 UTC, 0 replies.
- Re: [PR] KAFKA-14226: feat(connect:transform): Introduce FieldPath abstraction [kafka] - posted by "jeqo (via GitHub)" <gi...@apache.org> on 2024/05/06 16:46:04 UTC, 3 replies.
- Re: [PR] KAFKA-16287: Implement example tests for common rebalance callback [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/05/06 16:59:01 UTC, 7 replies.
- [jira] [Created] (KAFKA-16676) Security docs missing RPCs from KIP-714 and KIP-1000 - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/06 18:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16530) Fix high-watermark calculation to not assume the leader is in the voter set - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/06 19:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16531) Fix check-quorum calculation to not assume that the leader is in the voter set - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/06 19:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14237) Kafka TLS Doesn't Present Intermediary Certificates when using PEM - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/05/06 20:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16670) KIP-848 : Consumer will not receive assignment forever because of concurrent issue. - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/06 21:02:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-16670) KIP-848 : Consumer will not receive assignment forever because of concurrent issue. - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/06 21:02:00 UTC, 0 replies.
- Re: [PR] KAFKA-16356 RemoteLogMetadataSerde: Serializer via class-name dispatch removed and replaced with if-elseif-else conditions [kafka] - posted by "linu-shibu (via GitHub)" <gi...@apache.org> on 2024/05/06 21:44:22 UTC, 2 replies.
- Re: [PR] MINOR: Refactor Values class to fix checkstyle, add benchmark, optimize exceptions [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/06 22:24:13 UTC, 15 replies.
- [jira] [Resolved] (KAFKA-16356) Remove class-name dispatch in RemoteLogMetadataSerde - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/06 23:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16608) AsyncKafkaConsumer doesn't honor interrupted thread status on KafkaConsumer.poll(Duration) - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 00:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16539) Can't update specific broker configs in pre-migration mode - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 00:34:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16470) kafka-dump-log --offsets-decoder should support new records - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 00:50:00 UTC, 0 replies.
- Re: [PR] KAFKA-14885: fix kafka client connect to the broker that offline from… [kafka] - posted by "Stephan14 (via GitHub)" <gi...@apache.org> on 2024/05/07 02:48:48 UTC, 2 replies.
- [jira] [Created] (KAFKA-16677) Replace ClusterType#ALL and ClusterType#DEFAULT by Array - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 03:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16593) Rewrite DeleteConsumerGroupsTest by ClusterTestExtensions - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 06:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16677) Replace ClusterType#ALL and ClusterType#DEFAULT by Array - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 06:12:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16678) Remove unimplementedquorum from EndToEndAuthorizationTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 06:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16678) Remove unimplementedquorum from EndToEndAuthorizationTest - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2024/05/07 06:42:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16678) Remove unimplementedquorum from EndToEndAuthorizationTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 06:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16615) JoinGroup API for upgrading ConsumerGroup - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/07 07:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16679) Merge `DeleteRecordsCommandUnitTest` into `DeleteRecordsCommandTest`, `FeatureCommandUnitTest` into - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 07:12:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16677) Replace ClusterType#ALL and ClusterType#DEFAULT by Array - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 07:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16680) Make ClusterTestExtensions support SASL - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 08:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16589) Consider removing `ClusterInstance#createAdminClient` since callers are not sure whether they need to call close - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 08:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16681) Rewrite MiniKDC by Java - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 08:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16682) Rewrite JassTestUtils by Java - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 08:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16680) Make ClusterTestExtensions support SASL - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 08:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16683) Extract security-related helpers from scala.TestUtils to java class - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 08:48:00 UTC, 0 replies.
- [PR] KAFKA-16676: Add missing RPCs to security.html [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2024/05/07 09:07:15 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16679) Merge `DeleteRecordsCommandUnitTest` into `DeleteRecordsCommandTest`, `FeatureCommandUnitTest` into - posted by "Cheng-Kai, Zhang (Jira)" <ji...@apache.org> on 2024/05/07 09:28:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16679) Merge `DeleteRecordsCommandUnitTest` into `DeleteRecordsCommandTest`, `FeatureCommandUnitTest` into - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 10:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-12385) Remove FetchResponse#responseData - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 10:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16684) FetchResponse#responseData could return incorrect data - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 11:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16684) FetchResponse#responseData could return incorrect data - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 11:05:00 UTC, 1 replies.
- [PR] KAFKA-16678: Remove variable "unimplementedquorum" [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2024/05/07 11:50:35 UTC, 1 replies.
- Re: [PR] a slight change. [kafka] - posted by "gongxuanzhang (via GitHub)" <gi...@apache.org> on 2024/05/07 11:52:18 UTC, 6 replies.
- [jira] [Commented] (KAFKA-16682) Rewrite JassTestUtils by Java - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2024/05/07 12:05:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16682) Rewrite JassTestUtils by Java - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 12:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16685) RSM Task warn logs do not include parent exception trace - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/05/07 12:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16685) RLMTask warn logs do not include parent exception trace - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/05/07 12:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16685) RLMTask warning logs do not include parent exception trace - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/05/07 12:39:00 UTC, 2 replies.
- [PR] KAFKA-16685: Add parent exception to RLMTask warning logs [kafka] - posted by "jeqo (via GitHub)" <gi...@apache.org> on 2024/05/07 12:41:22 UTC, 2 replies.
- [PR] KAFKA-16640: Replace TestUtils#resource by scala.util.Using [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2024/05/07 12:55:52 UTC, 1 replies.
- [PR] KAFKA-10199: Handle assignment with new remove operation in state updater [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/07 12:59:30 UTC, 9 replies.
- [jira] [Resolved] (KAFKA-16307) fix EventAccumulator thread idle ratio metric - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/07 13:22:00 UTC, 0 replies.
- [PR] MINOR: Rewrite OptimizedUniformAssignmentBuilder#assignStickyPartitions to improve performance [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/07 14:01:47 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16645) CVEs in 3.7.0 docker image - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/05/07 15:03:00 UTC, 1 replies.
- [PR] MINOR: merge unit test down to the class of integration test [kafka] - posted by "KevinZTW (via GitHub)" <gi...@apache.org> on 2024/05/07 15:04:32 UTC, 1 replies.
- Re: [PR] MINOR: migrate ListConsumerGroupTest to use ClusterTestExtensions [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/07 15:27:02 UTC, 16 replies.
- Re: [PR] KAFKA-16362: Fix type-unsafety in KStreamKStreamJoin caused by isLeftSide [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/07 15:28:51 UTC, 17 replies.
- [jira] [Commented] (KAFKA-16681) Rewrite MiniKDC by Java - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2024/05/07 15:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-13328) Connect does not perform preflight validation for per-connector header converters - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/07 15:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-13329) Connect does not perform preflight validation for per-connector key and value converters - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/07 15:32:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16681) Rewrite MiniKDC by Java - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/07 15:38:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16686) Flakey tests in TopicBasedRemoteLogMetadataManagerTest - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/05/07 16:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16108) Backport fix for KAFKA-16093 to 3.7 - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/05/07 16:09:00 UTC, 2 replies.
- Re: [PR] KAFKA-15649: Handle directory failure timeout [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2024/05/07 16:10:51 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16656) Using a custom replication.policy.separator with DefaultReplicationPolicy - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/07 16:12:00 UTC, 3 replies.
- Re: [PR] Kafka-16668: Add tags support in ClusterTestExtension [kafka] - posted by "johnnychhsu (via GitHub)" <gi...@apache.org> on 2024/05/07 16:21:01 UTC, 25 replies.
- [jira] [Updated] (KAFKA-16250) Consumer group coordinator should perform sanity check on the offset commits. - posted by "Calvin Liu (Jira)" <ji...@apache.org> on 2024/05/07 16:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16687) Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0 - posted by "FTR (Jira)" <ji...@apache.org> on 2024/05/07 16:23:00 UTC, 0 replies.
- [PR] KAFKA-16686: Wait for given offset in TopicBasedRemoteLogMetadataManagerTest [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/05/07 16:24:15 UTC, 14 replies.
- [jira] [Commented] (KAFKA-16316) Make the restore behavior of GlobalKTables with custom processors configureable - posted by "Walker Carlson (Jira)" <ji...@apache.org> on 2024/05/07 16:25:00 UTC, 0 replies.
- Re: [PR] KAFKA-16598 Mirgrate `ResetConsumerGroupOffsetTest` to new test infra [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2024/05/07 16:34:01 UTC, 22 replies.
- [jira] [Commented] (KAFKA-16687) Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0 - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/07 16:44:00 UTC, 23 replies.
- [jira] [Assigned] (KAFKA-16687) Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0 - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/07 16:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16687) Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0 - posted by "FTR (Jira)" <ji...@apache.org> on 2024/05/07 17:13:00 UTC, 3 replies.
- Re: [PR] MINOR: set test global timeout as 10 mins [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/05/07 17:26:09 UTC, 0 replies.
- Re: [PR] KAFKA-16310 ListOffsets doesn't report the offset with maxTimestamp a… [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2024/05/07 17:48:37 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-15018) Potential tombstone offsets corruption for exactly-once source connectors - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/07 18:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16688) SystemTimer leaks resources on close - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/05/08 00:07:00 UTC, 0 replies.
- [PR] KAFKA-16688: Use helper method to shutdown ExecutorService [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/05/08 00:10:32 UTC, 6 replies.
- [PR] KAFKA-15045: (KIP-924) New interfaces and stubbed utility classes for pluggable TaskAssignors. [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/08 00:47:49 UTC, 5 replies.
- [PR] KAFKA-16264: Expose `producer.id.expiration.check.interval.ms` as dynamic broker configuration [kafka] - posted by "jeqo (via GitHub)" <gi...@apache.org> on 2024/05/08 01:10:00 UTC, 6 replies.
- [jira] [Created] (KAFKA-16689) Move LogValidatorTest to storage module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/08 01:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16264) Expose `producer.id.expiration.check.interval.ms` as dynamic broker configuration - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/05/08 01:37:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-14226) Introduce support for nested structures - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/05/08 01:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14226) Introduce support for nested structures - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/05/08 01:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16690) Support for nested structures: HeaderFrom - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/05/08 01:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16691) Support for nested structures: TimestampConverter - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/05/08 01:44:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16691) Support for nested structures: TimestampConverter - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/05/08 01:44:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16690) Support for nested structures: HeaderFrom - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/05/08 01:44:00 UTC, 0 replies.
- [PR] Fix Rate window size [kafka] - posted by "emitskevich-blp (via GitHub)" <gi...@apache.org> on 2024/05/08 02:26:12 UTC, 0 replies.
- Re: [PR] MINOR: Fix rate metric spikes [kafka] - posted by "emitskevich-blp (via GitHub)" <gi...@apache.org> on 2024/05/08 02:38:46 UTC, 33 replies.
- [jira] [Commented] (KAFKA-16689) Move LogValidatorTest to storage module - posted by "TaiJuWu (Jira)" <ji...@apache.org> on 2024/05/08 03:16:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16584) Make log processing summary configurable or debug - posted by "dujian (Jira)" <ji...@apache.org> on 2024/05/08 03:17:00 UTC, 1 replies.
- Re: [PR] Global state store restore custom processor [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/08 03:33:05 UTC, 0 replies.
- Re: [PR] [No review] Repro kafka-16217 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/08 03:33:06 UTC, 0 replies.
- Re: [PR] KAFKA-16218: Make partition reassignment completed as soon as adding replicas are in-sync [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/08 03:33:08 UTC, 0 replies.
- Re: [PR] MINOR: Add MetadataType metric from KIP-866 #15299 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/08 03:33:10 UTC, 0 replies.
- [PR] KAFKA-16643 Fix chaos modifier [kafka] - posted by "gongxuanzhang (via GitHub)" <gi...@apache.org> on 2024/05/08 03:41:59 UTC, 8 replies.
- [jira] [Assigned] (KAFKA-16684) FetchResponse#responseData could return incorrect data - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/08 03:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16689) Move LogValidatorTest to storage module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/08 03:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16679) Merge `DeleteRecordsCommandUnitTest` into `DeleteRecordsCommandTest`, `FeatureCommandUnitTest` into FeatureCommandTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/08 04:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16679) Merge unit test down to the class of integration test - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/08 04:26:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16678) Remove unimplementedquorum from EndToEndAuthorizationTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/08 04:31:00 UTC, 0 replies.
- [PR] [DON'T SEE THIS PR] debug for thread leak [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/08 04:42:58 UTC, 2 replies.
- [PR] [MINOR] Made the `supportedOperation` variable name more verbose [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2024/05/08 06:00:39 UTC, 1 replies.
- [PR] KAFKA-16691: [connect:transform] Support nested field paths on TimestampConverter [kafka] - posted by "jeqo (via GitHub)" <gi...@apache.org> on 2024/05/08 06:03:53 UTC, 5 replies.
- Re: [PR] KAFKA-16679 merge unit test down to the class of integration test [kafka] - posted by "KevinZTW (via GitHub)" <gi...@apache.org> on 2024/05/08 06:42:58 UTC, 7 replies.
- [jira] [Comment Edited] (KAFKA-16656) Using a custom replication.policy.separator with DefaultReplicationPolicy - posted by "Lenin Joseph (Jira)" <ji...@apache.org> on 2024/05/08 06:48:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16511) Leaking tiered segments - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/08 07:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16640) Replace TestUtils#resource by scala.util.Using - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/08 07:57:00 UTC, 0 replies.
- [PR] KAFKA-10199: Shutdown with new remove operation in state updater [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/08 08:23:26 UTC, 7 replies.
- [jira] [Commented] (KAFKA-16643) Add ModifierOrder checkstyle rule - posted by "xuanzhang gong (Jira)" <ji...@apache.org> on 2024/05/08 09:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16692) InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when - posted by "Johnson Okorie (Jira)" <ji...@apache.org> on 2024/05/08 10:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16692) InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when - posted by "Johnson Okorie (Jira)" <ji...@apache.org> on 2024/05/08 10:04:00 UTC, 2 replies.
- [PR] AKCORE-138: Integrated logic for handling maxDeliveryCount and moving SPSO with releaseAcquisitionLockOnTimeout in Share Partition [kafka] - posted by "chirag-wadhwa5 (via GitHub)" <gi...@apache.org> on 2024/05/08 11:35:49 UTC, 1 replies.
- [PR] KAFKA-10199: Remove queue-based remove from state updater [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/08 11:47:59 UTC, 1 replies.
- Re: [PR] Add s390x support to CI [kafka] - posted by "Prashant-Jagtap (via GitHub)" <gi...@apache.org> on 2024/05/08 12:46:17 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16685) RLMTask warning logs do not include parent exception trace - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/05/08 12:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16108) Backport fix for KAFKA-16093 to 3.7 - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/08 13:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14401) Connector/Tasks reading offsets can get stuck if underneath WorkThread dies - posted by "Sagar Rao (Jira)" <ji...@apache.org> on 2024/05/08 13:34:00 UTC, 1 replies.
- [PR] KAFKA-16677: Replace ClusterType#ALL and ClusterType#DEFAULT by Array [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/08 13:46:06 UTC, 16 replies.
- [PR] [MINOR] Renaming created to unassigned in IncrementalCooperativeAssignor#performTaskAssignment [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2024/05/08 14:31:51 UTC, 0 replies.
- [PR] KAFKA-16595: Introduce ClusterTemplate in ClusterTests [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2024/05/08 14:39:51 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-16339) Remove Deprecated "transformer" methods and classes - posted by "Vrushank Patel (Jira)" <ji...@apache.org> on 2024/05/08 15:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16692) InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/05/08 16:28:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16692) InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/05/08 16:30:00 UTC, 0 replies.
- [PR] MINOR: Fix streams javadoc links [kafka] - posted by "AyoubOm (via GitHub)" <gi...@apache.org> on 2024/05/08 17:13:07 UTC, 1 replies.
- [jira] [Created] (KAFKA-16693) Kafka Users are created with ACL entries and during performing operations allowed by ACL we see Denied Operation - posted by "Janardhana Gopalachar (Jira)" <ji...@apache.org> on 2024/05/08 17:19:00 UTC, 0 replies.
- Re: [PR] KAFKA-16493: Avoid unneeded subscription regex check if metadata version unchanged [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/05/08 17:35:08 UTC, 23 replies.
- [PR] Improve code example for using a transactional KafkaProducer [kafka] - posted by "matthiaskraaz (via GitHub)" <gi...@apache.org> on 2024/05/08 18:25:04 UTC, 0 replies.
- [jira] [Closed] (KAFKA-16665) Fail to get partition's position from within onPartitionsAssigned callback in new consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/08 19:00:00 UTC, 0 replies.
- [PR] KAFKA-16663: cancel write timeout TimerTask on successful event completion [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/05/08 22:39:48 UTC, 3 replies.
- [jira] [Created] (KAFKA-16694) Remove rack aware code in assignors temporarily due to performance - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2024/05/08 22:55:00 UTC, 0 replies.
- [PR] KAFKA-16694: Remove Rack Awareness Code from the Server Side Assignors [kafka] - posted by "rreddy-22 (via GitHub)" <gi...@apache.org> on 2024/05/09 00:03:11 UTC, 1 replies.
- [PR] MINOR: fix LogValidatorTest#checkNonCompressed [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/09 01:04:47 UTC, 9 replies.
- Re: [PR] KAFKA-16308 [1/N]: Create FeatureVersion interface and add `--feature` flag and handling to StorageTool [kafka] - posted by "artemlivshits (via GitHub)" <gi...@apache.org> on 2024/05/09 01:34:36 UTC, 82 replies.
- [jira] [Resolved] (KAFKA-16595) Introduce ClusterTemplate in ClusterTests - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2024/05/09 02:36:00 UTC, 0 replies.
- Re: [PR] KafkaDockerWrapper: correct KAFKA_HEAP_OPTS server property [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/09 03:33:14 UTC, 2 replies.
- [PR] MINOR: Add flag to read from specific partitions while checking consumer performance [kafka] - posted by "BOOTMGR (via GitHub)" <gi...@apache.org> on 2024/05/09 09:50:50 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16692) InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when upgrading from kafka 3.5 to 3.6 - posted by "Johnson Okorie (Jira)" <ji...@apache.org> on 2024/05/09 10:12:00 UTC, 7 replies.
- [jira] [Resolved] (KAFKA-16676) Security docs missing RPCs from KIP-714 and KIP-1000 - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/09 12:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16672) Fix flaky DedicatedMirrorIntegrationTest.testMultiNodeCluster - posted by "Johnny Hsu (Jira)" <ji...@apache.org> on 2024/05/09 13:30:00 UTC, 0 replies.
- [PR] KAFKA-16684: fix flaky DedicatedMirrorIntegrationTest [kafka] - posted by "johnnychhsu (via GitHub)" <gi...@apache.org> on 2024/05/09 13:46:07 UTC, 7 replies.
- [jira] [Assigned] (KAFKA-16672) Fix flaky DedicatedMirrorIntegrationTest.testMultiNodeCluster - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/09 14:33:00 UTC, 0 replies.
- [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 - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/05/09 14:34:00 UTC, 16 replies.
- [jira] [Created] (KAFKA-16695) Improve expired poll interval logging by showing exceeded time - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/09 15:10:00 UTC, 0 replies.
- Re: [PR] KAFKA-14133: Move StreamTaskTest to Mockito [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/05/09 15:16:12 UTC, 1 replies.
- [PR] KAFKA-16660: reduce the check interval to speedup DelegationTokenRequestsTest [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2024/05/09 15:16:15 UTC, 5 replies.
- [PR] MINOR: migrate DescribeConsumerGroupTest to use ClusterTestExtensions [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/09 15:24:20 UTC, 10 replies.
- [PR] KAFKA-16695: Improve expired poll logging [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/05/09 15:51:31 UTC, 18 replies.
- [jira] [Updated] (KAFKA-16695) Improve expired poll interval logging by showing exceeded time - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/09 15:56:00 UTC, 1 replies.
- [PR] KAFKA-15905 Restarts of MirrorCheckpointTask should not permanently i… [kafka] - posted by "edoardocomar (via GitHub)" <gi...@apache.org> on 2024/05/09 16:08:06 UTC, 46 replies.
- [jira] [Assigned] (KAFKA-7300) Add KafkaConsumer fetch-error-rate and fetch-error-total metrics - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/09 17:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16693) Kafka Users are created with ACL entries and during performing operations allowed by ACL we see Denied Operation - posted by "Janardhana Gopalachar (Jira)" <ji...@apache.org> on 2024/05/09 17:32:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16696) Remove the in-memory implementation of RSM and RLMM - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2024/05/09 17:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16696) Remove the in-memory implementation of RSM and RLMM - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2024/05/09 17:44:00 UTC, 1 replies.
- [PR] KAFKA-16696: Removed the in-memory implementation of RSM and RLMM [kafka] - posted by "kamalcph (via GitHub)" <gi...@apache.org> on 2024/05/09 17:44:31 UTC, 9 replies.
- [jira] [Assigned] (KAFKA-15905) Restarts of MirrorCheckpointTask should not permanently interrupt offset translation - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/09 18:29:00 UTC, 0 replies.
- [PR] MINOR; Validate at least one control record [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2024/05/09 20:01:49 UTC, 8 replies.
- [PR] Add demo template for transactional client [kafka] - posted by "k-raina (via GitHub)" <gi...@apache.org> on 2024/05/09 20:03:09 UTC, 6 replies.
- [jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache - posted by "Ayoub Omari (Jira)" <ji...@apache.org> on 2024/05/09 22:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16484) Support to define per broker/controller property by ClusterConfigProperty - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/10 02:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-12947) Replace EasyMock and PowerMock with Mockito for StreamsMetricsImplTest ... - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/10 03:10:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16660) reduce the check interval to speedup DelegationTokenRequestsTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/10 06:01:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16445) PATCH method for connector configuration - posted by "Ivan Yurchenko (Jira)" <ji...@apache.org> on 2024/05/10 08:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14133) Remaining EasyMock to Mockito tests - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/10 08:22:00 UTC, 0 replies.
- [PR] MINOR: Upgrade scala-logging to 3.9.5 [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2024/05/10 08:46:31 UTC, 4 replies.
- [PR] Increasing timeout for wait_for_loggers to 30s [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2024/05/10 08:56:54 UTC, 1 replies.
- [PR] KAFKA-16654:Refactor kafka.test.annotation.Type and ClusterTestExtensions [kafka] - posted by "TaiJuWu (via GitHub)" <gi...@apache.org> on 2024/05/10 12:05:21 UTC, 14 replies.
- [PR] MINOR: rewrite TopicBasedRemoteLogMetadataManagerTest by ClusterTestE… [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/10 12:29:40 UTC, 12 replies.
- [jira] [Assigned] (KAFKA-13473) Log cleaner Dynamic configs aren't applied after a restart - posted by "Jeel Jotaniya (Jira)" <ji...@apache.org> on 2024/05/10 12:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16445) PATCH method for connector configuration - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/10 13:37:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16692) InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when upgrading from kafka 3.5 to 3.6 - posted by "Johnson Okorie (Jira)" <ji...@apache.org> on 2024/05/10 14:45:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-16688) SystemTimer leaks resources on close - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/05/10 15:32:00 UTC, 0 replies.
- [PR] KAFKA-16667 Avoid stale read in KRaftMigrationDriver [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/05/10 16:13:23 UTC, 1 replies.
- [jira] [Created] (KAFKA-16697) Fix flaky kafka.api.SaslGssapiSslEndToEndAuthorizationTest#testProduceConsumeWithWildcardAcls - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/10 16:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16698) Fix flaky kafka.network.DynamicConnectionQuotaTest#testDynamicIpConnectionRateQuota - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/10 16:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16699) Have Streams treat InvalidPidMappingException like a ProducerFencedException - posted by "Walker Carlson (Jira)" <ji...@apache.org> on 2024/05/10 16:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16699) Have Streams treat InvalidPidMappingException like a ProducerFencedException - posted by "Walker Carlson (Jira)" <ji...@apache.org> on 2024/05/10 16:38:00 UTC, 0 replies.
- [PR] KAFKA-16699: Have Streams treat InvalidPidMappingException like a ProducerFencedException [kafka] - posted by "wcarlson5 (via GitHub)" <gi...@apache.org> on 2024/05/10 16:38:26 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16699) Have Streams treat InvalidPidMappingException like a ProducerFencedException - posted by "Walker Carlson (Jira)" <ji...@apache.org> on 2024/05/10 17:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16700) Kafka Streams: possible message loss on KTable-KTable FK Left Join - posted by "Karsten Stöckmann (Jira)" <ji...@apache.org> on 2024/05/10 19:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16701) Some SocketServerTest buffered close tests flaky failing locally - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/10 20:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16701) Some SocketServerTest buffered close tests flaky failing locally - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/10 20:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15804) Broker leaks ServerSocketChannel when exception is thrown from ZkConfigManager during startup - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/10 20:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16699) Have Streams treat InvalidPidMappingException like a ProducerFencedException - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/05/10 21:04:00 UTC, 0 replies.
- [PR] KAFKA-15045: (KIP-924): Implement ApplicationState and KafkaStreamsState [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/10 21:42:41 UTC, 0 replies.
- [jira] (KAFKA-16687) Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0 - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/10 21:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16513) Allow WriteTxnMarkers API with Alter Cluster Permission - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/05/10 22:32:00 UTC, 0 replies.
- [PR] MINOR: Add classic member session timeout to ClassicMemberMetadata [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/05/10 22:54:10 UTC, 4 replies.
- [jira] [Created] (KAFKA-16702) KafkaLog4jAppenderTest leaks producer instances - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/10 23:11:00 UTC, 0 replies.
- [PR] KAFKA-16702: Fix producer leaks in KafkaLog4jAppenderTest [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/10 23:15:07 UTC, 7 replies.
- [jira] [Created] (KAFKA-16703) SocketServer leaks ServerSocketChannel when port is already in-use - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/10 23:27:00 UTC, 0 replies.
- [PR] KAFKA-16703: Close serverChannel in SocketServer if unable to bind to a port [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/10 23:29:50 UTC, 2 replies.
- [jira] [Created] (KAFKA-16704) Fix flaky kafka.log.remote.RemoteIndexCacheTest#testIndexFileAlreadyExistOnDiskButNotInCache - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/11 01:49:00 UTC, 0 replies.
- Re: [PR] KAFKA-15045: (KIP-924 pt. 2) Implement ApplicationState and KafkaStreamsState [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/05/11 03:43:05 UTC, 5 replies.
- [jira] [Updated] (KAFKA-16669) Remove extra collection copy when generating DescribeAclsResource - posted by "Chia Chuan Yu (Jira)" <ji...@apache.org> on 2024/05/11 13:11:00 UTC, 0 replies.
- [PR] KAFKA-16669: Remove extra collection copy when generating DescribeAclsResource [kafka] - posted by "chiacyu (via GitHub)" <gi...@apache.org> on 2024/05/11 13:12:40 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16619) Unnecessary controller warning : "Loaded ZK migration state of NONE" - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2024/05/11 14:02:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-16619) Unnecessary controller warning : "Loaded ZK migration state of NONE" - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/05/11 14:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9401) High lock contention for kafka.server.FetchManager.newContext - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/11 15:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16679) Merge unit test down to the class of integration test - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/11 15:39:00 UTC, 0 replies.
- [PR] KAFKA-9401 Reduce contention for Fetch requests [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/05/11 16:13:59 UTC, 5 replies.
- [jira] [Updated] (KAFKA-9401) High lock contention for kafka.server.FetchManager.newContext - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/05/11 16:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16705) the flag "started" of RaftClusterInstance is false even though the cluster is started - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/11 17:56:00 UTC, 0 replies.
- [PR] improve log description of QuorumController [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2024/05/12 00:35:40 UTC, 6 replies.
- [jira] [Commented] (KAFKA-15648) QuorumControllerTest#testBootstrapZkMigrationRecord is flaky - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2024/05/12 02:00:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15648) QuorumControllerTest#testBootstrapZkMigrationRecord is flaky - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2024/05/12 02:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16671) Revisit SessionedProtocolIntegrationTest.ensureInternalEndpointIsSecured - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2024/05/12 02:35:00 UTC, 0 replies.
- Re: [PR] KAFKA-16671: enable test for ensureInternalEndpointIsSecured [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/12 02:35:31 UTC, 3 replies.
- Re: [PR] Update subscriptions at the end. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/12 03:33:53 UTC, 1 replies.
- [PR] Kafka-15444: Native docker image for Apache Kafka(KIP-974) [kafka] - posted by "kagarwal06 (via GitHub)" <gi...@apache.org> on 2024/05/12 03:47:04 UTC, 7 replies.
- Re: [PR] Kafka-15444: Native docker image for Apache Kafka(KIP-974) [kafka] - posted by "kagarwal06 (via GitHub)" <gi...@apache.org> on 2024/05/12 03:47:22 UTC, 0 replies.
- [jira] [Created] (KAFKA-16706) Refactor ReplicationQuotaManager/RLMQuotaManager to eliminate code duplication - posted by "Abhijeet Kumar (Jira)" <ji...@apache.org> on 2024/05/12 16:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16707) Kafka Kraft : adding Principal Type in StandardACL for matching with KafkaPrincipal of connected client - posted by "Franck L. (Jira)" <ji...@apache.org> on 2024/05/12 16:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16707) Kafka Kraft : adding Principal Type in StandardACL for matching with KafkaPrincipal of connected client - posted by "Franck L. (Jira)" <ji...@apache.org> on 2024/05/12 16:44:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16707) Kafka Kraft : adding Principal Type in StandardACL for matching with KafkaPrincipal of connected client in order to defined ACL with a notion of group - posted by "Franck LEDAY (Jira)" <ji...@apache.org> on 2024/05/12 17:09:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16708) Allow dynamic port for advertised listeners in Docker image - posted by "Chris Bono (Jira)" <ji...@apache.org> on 2024/05/12 18:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16708) Allow dynamic port for advertised listeners in Docker image - posted by "Chris Bono (Jira)" <ji...@apache.org> on 2024/05/12 18:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16603) Data loss when kafka connect sending data to Kafka - posted by "Anil Dasari (Jira)" <ji...@apache.org> on 2024/05/13 02:06:00 UTC, 6 replies.
- [PR] fix KAFKA-16705:the flag "started" of RaftClusterInstance is false even though the cluster is started [kafka] - posted by "gongxuanzhang (via GitHub)" <gi...@apache.org> on 2024/05/13 02:41:37 UTC, 9 replies.
- [jira] [Commented] (KAFKA-16705) the flag "started" of RaftClusterInstance is false even though the cluster is started - posted by "xuanzhang gong (Jira)" <ji...@apache.org> on 2024/05/13 03:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16709) move logDir within broker might cause log cleanup hanging - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/13 03:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16709) alter logDir within broker might cause log cleanup hanging - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/13 03:02:00 UTC, 1 replies.
- Re: [PR] KAFKA-12216; Improve flaky test reporting [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/13 03:33:16 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16705) the flag "started" of RaftClusterInstance is false even though the cluster is started - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/13 05:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16677) Replace ClusterType#ALL and ClusterType#DEFAULT by Array - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/13 06:26:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16663) CoordinatorRuntime write timer tasks should be cancelled once HWM advances - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/13 07:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16710) Continuously `makeFollower` may cause the replica fetcher thread to encounter an offset mismatch exception when `processPartitionData` - posted by "hudeqi (Jira)" <ji...@apache.org> on 2024/05/13 08:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16710) Continuously `makeFollower` may cause the replica fetcher thread to encounter an offset mismatch exception when `processPartitionData` - posted by "hudeqi (Jira)" <ji...@apache.org> on 2024/05/13 09:17:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-16587) Store subscription model for consumer group in group state - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/13 09:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16711) highestOffsetInRemoteStorage is not updated after logDir altering within broker - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/13 09:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16712) Race while setting RemoteLogMetadataTopicPartitioner in TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/05/13 10:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16712) Race while setting RemoteLogMetadataTopicPartitioner in TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/05/13 10:10:00 UTC, 0 replies.
- [PR] KAFKA-16710:Continuously `makeFollower` may cause the replica fetcher thread to encounter an offset mismatch exception [kafka] - posted by "hudeqi (via GitHub)" <gi...@apache.org> on 2024/05/13 10:21:55 UTC, 3 replies.
- [jira] [Created] (KAFKA-16713) Add new RPC definitions - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16715) Create KafkaShareConsumer interface - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16714) kafka-share-groups.sh supporting list and describe - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16716) Add AdminClient.describeShareGroups and AdminClient.listShareGroups - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16720) Add AdminClient.listShareGroupOffsets - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16719) Add AdminClient.deleteShareGroups - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16718) Add AdminClient.deleteShareGroupOffsets - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16717) Add AdminClient.alterShareGroupOffsets - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16721) Add exceptions for the new error codes - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16722) Add ConsumerGroupPartitionAssignor and ShareGroupPartitionAssignor - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16723) Add kafka-console-share-consumer.sh - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16725) Add broker configurations - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16724) Add new options for kafka-producer-perf-test.sh - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:20:00 UTC, 0 replies.
- [PR] KAFKA-14588 [3/N] ConfigCommandTest rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/05/13 12:20:21 UTC, 8 replies.
- [jira] [Created] (KAFKA-16728) Add dynamic group configuration for heartbeat interval and session timeout - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16727) Add dynamic group configuration for record lock duration - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16726) Add dynamic group configuration for offset reset - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16729) Support for read-committed isolation level - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16731) Support for share-group-metrics in the broker - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16730) Initial code for share-group consumer - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16733) Add support for formatting new records written to offsets topic - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16732) Support for share-coordinator-metrics in the broker - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16734) Add support for formatting records written to share-group state topic - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 12:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16735) Deprecate offsets.commit.required.acks in 3.8 - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/13 12:24:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16736) Remove offsets.commit.required.acks in 4.0 - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/13 12:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16735) Deprecate offsets.commit.required.acks in 3.8 - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/13 12:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16736) Remove offsets.commit.required.acks in 4.0 - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/13 12:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16671) Revisit SessionedProtocolIntegrationTest.ensureInternalEndpointIsSecured - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/13 12:30:00 UTC, 0 replies.
- [PR] KAFKA-16735; Deprecate offsets.commit.required.acks [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/13 12:41:23 UTC, 3 replies.
- [jira] [Created] (KAFKA-16737) Clean up KafkaConsumerTest TODOs enabling tests for new consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/13 13:34:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16603) Data loss when kafka connect sending data to Kafka - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/13 13:34:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16700) Kafka Streams: possible message loss on KTable-KTable FK Left Join - posted by "Ayoub Omari (Jira)" <ji...@apache.org> on 2024/05/13 14:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16700) Kafka Streams: possible message loss on KTable-KTable FK Left Join - posted by "Ayoub Omari (Jira)" <ji...@apache.org> on 2024/05/13 14:07:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-16245) DescribeConsumerGroupTest failing - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/13 14:11:00 UTC, 1 replies.
- [PR] MINOR: Add coverage for MM2 heartbeats topic detection [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/13 14:22:01 UTC, 1 replies.
- [PR] KAFKA-16223: Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/13 14:26:13 UTC, 10 replies.
- [PR] MINOR: Move `group-coordinator` import control to its own file [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/13 14:29:39 UTC, 1 replies.
- [jira] [Created] (KAFKA-16738) Returns BaseRecords instead of MemoryRecords - posted by "Zhenyu Luo (Jira)" <ji...@apache.org> on 2024/05/13 15:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16737) Clean up KafkaConsumerTest TODOs enabling tests for new consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/13 15:15:00 UTC, 3 replies.
- [PR] KAFKA-16738: Returns BaseRecords instead of MemoryRecords [kafka] - posted by "luozhenyu (via GitHub)" <gi...@apache.org> on 2024/05/13 15:16:42 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-16737) Clean up KafkaConsumerTest TODOs enabling tests for new consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/13 15:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16738) Returns BaseRecords instead of MemoryRecords - posted by "Zhenyu Luo (Jira)" <ji...@apache.org> on 2024/05/13 15:21:00 UTC, 0 replies.
- [PR] MINOR: Use ClusterTemplate in ApiVersionsRequestTest [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2024/05/13 15:40:55 UTC, 1 replies.
- [PR] MINOR: add logging for testRecordThreadIdleRatioTwoThreads [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/05/13 16:27:50 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15250) ConsumerNetworkThread is running tight loop - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/13 16:30:00 UTC, 0 replies.
- [PR] FIX 16705 the flag "started" of RaftClusterInstance is false even though the cluster is started [kafka] - posted by "gongxuanzhang (via GitHub)" <gi...@apache.org> on 2024/05/13 16:41:16 UTC, 1 replies.
- Re: [PR] MINOR: fix flaky testRecordThreadIdleRatioTwoThreads test [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/05/13 17:19:30 UTC, 2 replies.
- [jira] [Created] (KAFKA-16739) Exclude protected variables from aggregated JavaDocs - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/13 17:38:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16740) Define skeleton for SharePartitionManager and SharePartition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:38:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16742) Add ShareGroupDescribe API support in GroupCoordinator - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16741) Add SharGroupHeartbeat API support in GroupCoordinator - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16743) Add support for share group heartbeat in KafkaApis - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16745) Add support for share fetch request in KafkaApis - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16744) Add support for share group describe in KafkaApis - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16743) Add support for share group heartbeat in KafkaApis - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16746) Add support for share acknowledgement request in KafkaApis - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16748) Implement share response handling in SharePartitionManager - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16747) Implement share sessions and context - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16750) Implement acknowledge API in SharePartitionManager - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16749) Implement share fetch messages - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16751) Implement release acquired records in SharePartitionManager - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16754) Implement release acquired records functionality in SharePartition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16752) Implement acquire functionality in SharePartition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16753) Implement acknowledge functionality in SharePartition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16756) Implement max delivery count functionality in SharePartition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16755) Implement lock timeout functionality in SharePartition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/13 17:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16735) Deprecate offsets.commit.required.acks in 3.8 - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/13 18:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16117) Add Integration test for checking if the correct assignor is chosen - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/13 18:37:00 UTC, 0 replies.
- [PR] KAFKA-16739: Exclude protected members from aggregated release Javadocs [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/13 18:37:39 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-14701) More broker side partition assignor to common - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/13 18:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15578) Run System Tests for Old protocol in the New Coordinator - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/13 18:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16687) Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0 - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/13 18:52:00 UTC, 0 replies.
- [PR] MINOR: Change sys test describe topic parsing to improve extensibility [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/05/13 19:05:33 UTC, 3 replies.
- [PR] MINOR: Migrate tests in o.a.k.streams to JUnit 5 (except KafkaStreamsTest) [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/13 19:57:31 UTC, 4 replies.
- [PR] Adds the correct specific paths to codeartifact [kafka] - posted by "Muen342 (via GitHub)" <gi...@apache.org> on 2024/05/13 20:00:24 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-10369) Introduce Distinct operation in KStream - posted by "Ayoub Omari (Jira)" <ji...@apache.org> on 2024/05/13 20:53:00 UTC, 0 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 3) Implement KafkaStreamsAssignment [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/13 20:56:25 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16361) Rack aware sticky assignor minQuota violations - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/05/13 21:14:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-16757) Fix broker re-registration issues around MV 3.7-IV2 - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/05/13 23:13:00 UTC, 0 replies.
- [PR] KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2 [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/05/13 23:19:23 UTC, 14 replies.
- Re: [PR] KIP-966 unclean recovery elect leader request [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/05/13 23:49:10 UTC, 10 replies.
- Re: [PR] KAFKA-16705 the flag "started" of RaftClusterInstance is false even though the cluster is starte [kafka] - posted by "gongxuanzhang (via GitHub)" <gi...@apache.org> on 2024/05/14 01:36:17 UTC, 0 replies.
- [PR] KAFKA-16705 the flag "started" of RaftClusterInstance is false even though the cluster is started [kafka] - posted by "gongxuanzhang (via GitHub)" <gi...@apache.org> on 2024/05/14 01:44:21 UTC, 10 replies.
- [jira] [Comment Edited] (KAFKA-16361) Rack aware sticky assignor minQuota violations - posted by "li xiangyuan (Jira)" <ji...@apache.org> on 2024/05/14 02:40:00 UTC, 3 replies.
- Re: [PR] KAFKA-15170: CooperativeStickyAssignor may fail adjust assignment [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/05/14 03:30:56 UTC, 13 replies.
- [PR] KAFKA-16711: make sure update highestOffsetInRemoteStorage after log dir change [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/05/14 04:04:04 UTC, 7 replies.
- Re: [PR] KAFKA-16514: backdoor for modifying internal leave.group.on.close config [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/05/14 05:25:49 UTC, 1 replies.
- [jira] [Created] (KAFKA-16758) Extend Consumer#close with option to leave the group or not - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/05/14 05:40:00 UTC, 0 replies.
- [PR] MINOR: revisit LogValidatorTest#checkRecompression [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/14 05:47:08 UTC, 5 replies.
- [jira] [Commented] (KAFKA-16758) Extend Consumer#close with option to leave the group or not - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/05/14 05:49:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-16694) Remove rack aware code in assignors temporarily due to performance - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/14 07:15:00 UTC, 0 replies.
- [PR] MINOR: Rename `Record` to `CoordinatorRecord` [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/14 07:26:53 UTC, 3 replies.
- [PR] MINOR: Fix TargetAssignmentBuilderBenchmark [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/14 07:38:01 UTC, 1 replies.
- [jira] [Created] (KAFKA-16759) Invalid client telemetry transition on consumer close - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/14 08:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16760) alterReplicaLogDirs failed even if responded with none error - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/14 09:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16760) alterReplicaLogDirs failed even if responded with none error - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/14 09:07:00 UTC, 6 replies.
- [jira] [Updated] (KAFKA-16760) alterReplicaLogDirs failed even if responded with none error - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/14 09:07:00 UTC, 0 replies.
- [PR] KAFKA-16709: abortAndPauseCleaning only when future log is not existed [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/05/14 10:13:49 UTC, 22 replies.
- [jira] [Commented] (KAFKA-16664) Re-add EventAccumulator.take(timeout) - posted by "Quoc Phong Dang (Jira)" <ji...@apache.org> on 2024/05/14 10:20:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16761) ZkClusterInstance#start does not create ClusterConfigurableIntegrationHarness - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/14 14:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16758) Extend Consumer#close with option to leave the group or not - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/14 14:37:00 UTC, 1 replies.
- Re: [PR] KAFKA-13115 Update doSend doc about possible blocking [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2024/05/14 14:50:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13115) doSend can be blocking - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/14 14:51:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-13115) doSend can be blocking - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/14 14:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13115) Document that doSend can be blocking - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/14 14:52:00 UTC, 0 replies.
- Re: [PR] KAFKA-15911: making sure the follower is making progress [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2024/05/14 14:53:26 UTC, 0 replies.
- [PR] KAFKA-16513: Add test for WriteTxnMarkers with AlterCluster permission [kafka] - posted by "nikramakrishnan (via GitHub)" <gi...@apache.org> on 2024/05/14 15:06:01 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16675) Move rebalance callback test for positions to callbacks test file - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/14 15:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16639) AsyncKafkaConsumer#close does not send heartbeat to leave group - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/14 15:36:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16599) LegacyConsumer: Always await async commit callbacks in commitSync and close - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/14 15:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16406) Split long-running consumer integration test - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/14 15:38:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16406) Split long-running consumer integration test - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/14 15:39:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15279) Implement client support for KIP-848 client-side assigner RPCs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/14 15:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15282) Implement client support for KIP-848 client-side assignors - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/14 15:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15697) Add local assignor and ensure it cannot be used with server side assignor - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/14 15:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15284) Implement ConsumerGroupProtocolVersionResolver to determine consumer group protocol - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/14 15:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16759) Invalid client telemetry transition on consumer close - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/14 15:50:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-16406) Split long-running consumer integration test - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/14 16:00:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16406) Split long-running consumer integration test - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/14 16:00:00 UTC, 0 replies.
- [PR] Cherry-pick KAFKA-16539 to 3.7 [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/05/14 16:01:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16762) SyncGroup API for upgrading ConsumerGroup - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/05/14 16:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16762) SyncGroup API for upgrading ConsumerGroup - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/05/14 16:07:00 UTC, 0 replies.
- [PR] KAFKA-16762: SyncGroup API for upgrading ConsumerGroup [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/05/14 16:13:07 UTC, 20 replies.
- [jira] [Created] (KAFKA-16763) Upgrade to scala 2.12.19 and scala 2.13.14 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/14 16:20:00 UTC, 0 replies.
- [PR] MINOR: Fix warnings in streams javadoc [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/14 16:26:08 UTC, 2 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 4) Generify rack graph solving utilities [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/14 17:01:24 UTC, 2 replies.
- [jira] [Updated] (KAFKA-14567) Kafka Streams crashes after ProducerFencedException - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/05/14 17:09:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-14567) Kafka Streams crashes after ProducerFencedException - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/05/14 17:09:00 UTC, 0 replies.
- [PR] KAFKA-16759: Handle telemetry push response while terminating [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2024/05/14 17:24:39 UTC, 1 replies.
- [jira] [Created] (KAFKA-16764) New consumer should throw InvalidTopicException on poll when invalid topic in metadata - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/14 19:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16764) New consumer should throw InvalidTopicException on poll when invalid topic in metadata - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/14 19:45:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16765) NioEchoServer leaks accepted SocketChannel instances due to race condition - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/14 20:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16766) New consumer offsetsForTimes timeout exception does not have the proper message - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/14 20:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16766) New consumer offsetsForTimes timeout exception does not have the proper message - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/14 20:35:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16637) AsyncKafkaConsumer removes offset fetch responses from cache too aggressively - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/14 20:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16767) KRaft should track HWM outside the log layer - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/14 21:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16277) CooperativeStickyAssignor does not spread topics evenly among consumer group - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/05/15 00:13:00 UTC, 0 replies.
- Re: [PR] KAFKA-16277: AbstractStickyAssignor - Sort owned TopicPartitions by partition when reassigning [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/05/15 00:13:14 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15170) CooperativeStickyAssignor cannot adjust assignment correctly - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/05/15 00:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15170) CooperativeStickyAssignor cannot adjust assignment correctly - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/05/15 00:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16763) Upgrade to scala 2.12.19 and scala 2.13.14 - posted by "黃竣陽 (Jira)" <ji...@apache.org> on 2024/05/15 01:20:00 UTC, 0 replies.
- [PR] Upgrade to scala 2.12.19 and scala 2.13.14 [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2024/05/15 01:41:42 UTC, 0 replies.
- [jira] [Created] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/15 01:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/15 02:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16765) NioEchoServer leaks accepted SocketChannel instances due to race condition - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/15 02:26:00 UTC, 0 replies.
- [PR] [DO NOT MERGE] KIP-924 rack info API option 2: introduce TaskInfo with complete task metadata [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/05/15 02:28:48 UTC, 0 replies.
- [PR] [DO NOT MERGE] KIP-924 rack info API option 1: add #taskIdToPartitionsRackIds and PartitionRackIds [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/05/15 02:29:40 UTC, 0 replies.
- Re: [PR] KAFKA-16763: Upgrade to scala 2.12.19 and scala 2.13.14 [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2024/05/15 03:18:00 UTC, 11 replies.
- Re: [PR] MINOR: update leaderAndEpoch before initializing metadata publishers [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/15 03:33:22 UTC, 0 replies.
- Re: [PR] KAFKA-15050: format the prompts in the quickstart [kafka] - posted by "joobisb (via GitHub)" <gi...@apache.org> on 2024/05/15 03:40:48 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16764) New consumer should throw InvalidTopicException on poll when invalid topic in metadata - posted by "appchemist (Jira)" <ji...@apache.org> on 2024/05/15 03:45:00 UTC, 1 replies.
- [PR] KAFKA-16764: New consumer should throw InvalidTopicException on poll … [kafka] - posted by "appchemist (via GitHub)" <gi...@apache.org> on 2024/05/15 04:08:03 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-16671) Revisit SessionedProtocolIntegrationTest.ensureInternalEndpointIsSecured - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/15 04:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16763) Upgrade to scala 2.12.19 and scala 2.13.14 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/15 04:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16616) refactor mergeWith in MetadataSnapshot - posted by "Cao Manh Dat (Jira)" <ji...@apache.org> on 2024/05/15 06:57:00 UTC, 0 replies.
- [jira] (KAFKA-16616) refactor mergeWith in MetadataSnapshot - posted by "Cao Manh Dat (Jira)" <ji...@apache.org> on 2024/05/15 07:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16769) Delete deprecated add.source.alias.to.metrics configuration - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/15 07:40:00 UTC, 0 replies.
- [PR] KAFKA-16712: Fix race in TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/05/15 07:52:22 UTC, 6 replies.
- [jira] [Comment Edited] (KAFKA-16760) alterReplicaLogDirs failed even if responded with none error - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/05/15 08:58:00 UTC, 2 replies.
- Re: [PR] KAFKA-16599: LegacyConsumer should always await pending async commits on commitSync and close [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/05/15 09:22:02 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/15 12:17:00 UTC, 1 replies.
- [PR] KAFKA-7342: Migrate tests in remaining packages in o.a.k.streams [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/15 12:42:06 UTC, 2 replies.
- [jira] [Commented] (KAFKA-15242) FixedKeyProcessor testing is unusable - posted by "Matej Sprysl (Jira)" <ji...@apache.org> on 2024/05/15 13:34:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-16329) Remove Deprecated Task/ThreadMetadata classes and related methods - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/15 14:31:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16333) Removed Deprecated methods KTable#join - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/15 14:31:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16330) Remove Deprecated methods/variables from TaskId - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/15 14:32:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16770) Coalesce records into bigger batches - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/15 14:41:00 UTC, 0 replies.
- [PR] KAFKA-16770; [1/N] Coalesce records into bigger batches [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/15 14:48:38 UTC, 16 replies.
- [PR] KAFKA-16675: Refactored and new rebalance callbacks integration tests [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/05/15 14:49:14 UTC, 7 replies.
- [PR] KAFKA-16684: Remove cache in responseData [kafka] - posted by "johnnychhsu (via GitHub)" <gi...@apache.org> on 2024/05/15 15:10:32 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16448) Add Kafka Streams exception handler for exceptions occuring during processing (KIP-1033) - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/15 15:13:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-16771) First log directory printed twice when formatting storage - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/15 15:13:00 UTC, 0 replies.
- Re: [PR] KAFKA-16606 Gate JBOD configuration on 3.7-IV2 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/15 15:13:46 UTC, 5 replies.
- [PR] MINOR: Remove unused method in ToolsUtils [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/15 15:27:55 UTC, 1 replies.
- [jira] [Created] (KAFKA-16772) Introduce a type for kraft.version - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/15 15:47:00 UTC, 0 replies.
- [PR] Kafka-10551: Add topic id support to produce request and response [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/05/15 15:53:13 UTC, 0 replies.
- Re: [PR] Refactor SSL/SASL admin integration tests to not use a custom authorizer [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/15 16:02:23 UTC, 2 replies.
- [PR] MINOR: Remove usage of Stream API in CoordinatorRecordHelpers [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/15 16:29:55 UTC, 2 replies.
- [jira] [Created] (KAFKA-16773) Fix flaky QuorumControllerTest#testDelayedConfigurationOperations - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/15 18:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16774) fix flaky StreamThreadTest#shouldCloseAllTaskProducersOnCloseIfEosEnabled - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/15 18:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16775) Fix flaky PlaintextAdminIntegrationTest#testCreateExistingTopicsThrowTopicExistsException - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/15 18:23:00 UTC, 0 replies.
- Re: [PR] MINOR: fix timeouts of EosIntegrationTest [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/15 18:55:15 UTC, 0 replies.
- [jira] [Created] (KAFKA-16776) Builds flaky-failing with leaked client-metrics-reaper thread - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/15 19:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16776) Builds flaky-failing with leaked client-metrics-reaper thread - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/15 19:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16622) Mirromaker2 first Checkpoint not emitted until consumer group fully catches up once - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/15 19:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16777) New consumer should throw NoOffsetForPartitionException on continuous poll zero if no reset strategy - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/15 20:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16777) New consumer should throw NoOffsetForPartitionException on continuous poll zero if no reset strategy - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/15 20:26:00 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-16626) Uuid to String for subscribed topic names in assignment spec - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/05/15 20:35:00 UTC, 0 replies.
- [PR] KAFKA-16626: Lazily convert subscribed topic names to topic ids [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/05/15 20:44:31 UTC, 14 replies.
- [PR] InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when upgrading from kafka [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/05/15 21:38:53 UTC, 0 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 5) Add rack information to ApplicationState [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/15 21:58:35 UTC, 13 replies.
- [jira] [Created] (KAFKA-16778) AsyncKafkaConsumer fetcher might occasionally try to fetch to a revoked partition - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/15 22:10:00 UTC, 0 replies.
- [PR] KAFKA-16448 [WIP]: Add Kafka Streams exception handler for exceptions occuring during processing [kafka] - posted by "loicgreffier (via GitHub)" <gi...@apache.org> on 2024/05/15 22:25:09 UTC, 3 replies.
- [jira] [Created] (KAFKA-16779) Kafka retains logs past specified retention - posted by "Nicholas Feinberg (Jira)" <ji...@apache.org> on 2024/05/15 22:33:00 UTC, 0 replies.
- Re: [PR] Add Integration tests for the the KIP-966 [kafka] - posted by "CalvinConfluent (via GitHub)" <gi...@apache.org> on 2024/05/15 23:47:20 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16771) First log directory printed twice when formatting storage - posted by "xuanzhang gong (Jira)" <ji...@apache.org> on 2024/05/16 01:49:00 UTC, 1 replies.
- Re: [PR] Enable KRaft for BaseAdminIntegrationTest and SaslSslAdminIntegrationTest [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/16 03:33:38 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-15242) FixedKeyProcessor testing is unusable - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/16 05:33:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16774) fix flaky StreamThreadTest#shouldCloseAllTaskProducersOnCloseIfEosEnabled - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/16 05:34:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16774) fix flaky StreamThreadTest#shouldCloseAllTaskProducersOnCloseIfEosEnabled - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/16 05:35:00 UTC, 5 replies.
- Re: [PR] KAFKA-15307: Update/errors for deprecated config [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/05/16 06:14:20 UTC, 1 replies.
- [PR] KAFKA-16625: Reverse lookup map from topic partitions to members [kafka] - posted by "rreddy-22 (via GitHub)" <gi...@apache.org> on 2024/05/16 06:22:48 UTC, 34 replies.
- [jira] [Updated] (KAFKA-16779) Kafka retains logs past specified retention - posted by "Lin Siyuan (Jira)" <ji...@apache.org> on 2024/05/16 07:36:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16779) Kafka retains logs past specified retention - posted by "Lin Siyuan (Jira)" <ji...@apache.org> on 2024/05/16 07:38:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16771) First log directory printed twice when formatting storage - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 07:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16780) Txn consumer exerts pressure on remote storage when reading non-txn topic - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2024/05/16 08:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16780) Txn consumer exerts pressure on remote storage when reading non-txn topic - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2024/05/16 08:53:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16781) Expose advertised.listeners in controller node - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/16 09:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16781) Expose advertised.listeners in controller node - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/16 09:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16539) Can't update specific broker configs in pre-migration mode - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 09:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16539) Can't update specific broker configs in pre-migration mode - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 09:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16781) Expose advertised.listeners in controller node - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2024/05/16 09:49:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16781) Expose advertised.listeners in controller node - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 09:50:00 UTC, 0 replies.
- Re: [PR] [Draft] KAFKA-16764: New consumer should throw InvalidTopicException on poll when invalid topic in metadata [kafka] - posted by "appchemist (via GitHub)" <gi...@apache.org> on 2024/05/16 10:00:01 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-16668) Enable to set tags by `ClusterTest` - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 10:03:00 UTC, 0 replies.
- Re: [PR] KAFKA-14588 [4/N] ConfigCommandTest rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/05/16 10:41:41 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-16774) fix flaky StreamThreadTest#shouldCloseAllTaskProducersOnCloseIfEosEnabled - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 11:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15541) Improved StateStore Iterator metrics for detecting leaks - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2024/05/16 11:28:00 UTC, 0 replies.
- [PR] KAFKA-15541: Add num-open-iterators metric [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2024/05/16 11:31:33 UTC, 7 replies.
- [jira] [Created] (KAFKA-16782) Some partition's segments are suddenly not deleted anymore - posted by "Roland Sommer (Jira)" <ji...@apache.org> on 2024/05/16 12:48:00 UTC, 0 replies.
- [PR] MINOR: Refactor write timeout in CoordinatorRuntime [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/16 12:51:55 UTC, 5 replies.
- [PR] MINOR: Add debug enablement check when using log.debug [kafka] - posted by "johnnychhsu (via GitHub)" <gi...@apache.org> on 2024/05/16 12:57:49 UTC, 1 replies.
- Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/05/16 13:01:36 UTC, 19 replies.
- [jira] [Created] (KAFKA-16783) Migrate RemoteLogMetadataManagerTest to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 13:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16784) Migrate TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 13:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16783) Migrate RemoteLogMetadataManagerTest to new test infra - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2024/05/16 13:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16783) Migrate RemoteLogMetadataManagerTest to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 13:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16785) Migrate TopicBasedRemoteLogMetadataManagerRestartTest to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 13:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16784) Migrate TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 13:36:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16783) Migrate RemoteLogMetadataManagerTest to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 13:37:00 UTC, 0 replies.
- Re: [PR] KAFKA-16992: InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when upgrading from kafka [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/16 13:49:26 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-16774) fix flaky StreamThreadTest#shouldCloseAllTaskProducersOnCloseIfEosEnabled - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/05/16 13:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16786) New consumer subscribe should not require the deprecated partition.assignment.strategy - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/16 14:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16786) New consumer subscribe should not require the deprecated partition.assignment.strategy - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/16 14:41:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16786) New consumer subscribe should not require the deprecated partition.assignment.strategy - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/16 14:42:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-16786) New consumer subscribe should not require the deprecated partition.assignment.strategy - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/05/16 14:54:00 UTC, 0 replies.
- [PR] KAFKA-16774: Delete flaky test since it is redundant [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/16 15:08:36 UTC, 2 replies.
- [PR] KAFKA-16544 DescribeTopicsResult#allTopicIds and DescribeTopicsResult#allTopicNames should return null instead of throwing NPE [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2024/05/16 15:21:45 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16350) StateUpdater does not init transaction after canceling task close action - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/05/16 15:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16350) StateUpdater does not init transaction after canceling task close action - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/05/16 15:32:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15723) KRaft support in ListOffsetsRequestTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/16 15:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15723) KRaft support in ListOffsetsRequestTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/16 15:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16785) Migrate TopicBasedRemoteLogMetadataManagerRestartTest to new test infra - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2024/05/16 16:10:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16448) Add Kafka Streams exception handler for exceptions occuring during processing (KIP-1033) - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/16 16:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16414) Inconsistent active segment expiration behavior between retention.ms and retention.bytes - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/05/16 16:49:00 UTC, 8 replies.
- [jira] [Assigned] (KAFKA-16785) Migrate TopicBasedRemoteLogMetadataManagerRestartTest to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/16 17:39:00 UTC, 0 replies.
- Re: [PR] KAFKA-16105: Reassignment fix [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/16 17:59:36 UTC, 8 replies.
- [jira] [Commented] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task - posted by "Karsten Stöckmann (Jira)" <ji...@apache.org> on 2024/05/16 21:10:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16787) Remove TRACE level logging from AsyncKafkaConsumer hot path - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/16 22:44:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16787) Remove TRACE level logging from AsyncKafkaConsumer hot path - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/16 22:44:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16787) Remove TRACE level logging from AsyncKafkaConsumer hot path - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/16 22:46:00 UTC, 0 replies.
- [PR] KAFKA-16787: Remove TRACE level logging from AsyncKafkaConsumer hot path [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/05/16 23:37:38 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task - posted by "Colt McNealy (Jira)" <ji...@apache.org> on 2024/05/17 00:09:00 UTC, 4 replies.
- Re: [PR] KAFKA-15104: Fix flaky tests in MetadataQuorumCommandTest [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/17 03:33:08 UTC, 0 replies.
- Re: [PR] KAFKA-16179; Stop processing requests before stopping publishing [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/17 03:33:09 UTC, 0 replies.
- Re: [PR] KAFKA-14768_KIP913: add new method to provide possibility for warming up first record's sending and reducing the max.block.ms safely. [kafka] - posted by "AlEmerich (via GitHub)" <gi...@apache.org> on 2024/05/17 08:25:38 UTC, 0 replies.
- Re: [PR] KAFKA-15319: Upgrade rocksdb to fix CVE-2022-37434 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/17 09:34:57 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16708) Allow dynamic port for advertised listeners in Docker image - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2024/05/17 09:38:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16788) Resource leakage due to absence of close() call on connector start failure - posted by "Ashok (Jira)" <ji...@apache.org> on 2024/05/17 10:43:00 UTC, 0 replies.
- [PR] MINOR: use try-with resources in ClientMetricsManagerTest [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/05/17 12:20:01 UTC, 1 replies.
- [PR] KAFKA-16783: Migrate RemoteLogMetadataManagerTest to new test infra [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/17 12:41:30 UTC, 4 replies.
- [jira] [Commented] (KAFKA-16784) Migrate TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest to new test infra - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2024/05/17 12:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16789) Thread leak detection checks for incorrect QuorumController thread name - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/05/17 13:34:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16789) Thread leak detection checks for incorrect QuorumController thread name - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/05/17 13:34:00 UTC, 0 replies.
- Re: [PR] KAFKA-16066: Upgrade apacheds to 2.0.0.AM27 With apache kerby [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/17 13:48:00 UTC, 0 replies.
- Re: [PR] KAFKA-15746: KRaft support in ControllerMutationQuotaTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/17 13:53:23 UTC, 2 replies.
- [PR] KAFKA-16789: Fix thread leak detection for event handler threads [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/05/17 14:06:41 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-16784) Migrate TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/17 14:10:00 UTC, 0 replies.
- [PR] KAFKA-12399: Deprecate KafkaLog4jAppender [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/17 14:13:16 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-16762) SyncGroup API for upgrading ConsumerGroup - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/17 14:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/05/17 14:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15197) Flaky test MirrorConnectorsIntegrationExactlyOnceTest.testOffsetTranslationBehindReplicationFlow() - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/17 16:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16758) Extend Consumer#close with option to leave the group or not - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/17 16:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14517) Implement regex subscriptions - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/17 16:27:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-16763) Upgrade to scala 2.12.19 and scala 2.13.14 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/17 16:37:00 UTC, 0 replies.
- [PR] KAFKA-16252; Dynamic KRaft network manager and channel [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2024/05/17 16:53:05 UTC, 23 replies.
- [jira] [Created] (KAFKA-16790) Calls to RemoteLogManager are made before it is configured - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/17 17:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16790) Calls to RemoteLogManager are made before it is configured - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/17 17:10:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16788) Resource leakage due to absence of close() call on connector start failure - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/17 17:45:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16790) Calls to RemoteLogManager are made before it is configured - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/17 17:49:00 UTC, 7 replies.
- [PR] MINOR: fix flaky testRecordThreadIdleRatio [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/05/17 19:06:43 UTC, 10 replies.
- [jira] [Created] (KAFKA-16791) Add thread detection to ClusterTestExtensions - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/17 19:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16792) Enable related unit tests that fail to fetch offsets only for new consumer with to poll(0) - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/17 19:21:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16792) Enable related unit tests that fail only for new consumer with to poll(0) - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/17 19:21:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16764) New consumer should throw InvalidTopicException on poll when invalid topic in metadata - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/17 19:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0) - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/17 19:27:00 UTC, 7 replies.
- Re: [PR] KAFKA-7342: Migrate tests in o.a.k.streams to JUnit 5 (except KafkaStreamsTest) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/17 19:31:07 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16544) DescribeTopicsResult#allTopicIds and DescribeTopicsResult#allTopicNames should return null instead of throwing NPE - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/17 19:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15723) KRaft support in ListOffsetsRequestTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/17 19:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16793) Heartbeat API for upgrading ConsumerGroup - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/05/17 20:22:00 UTC, 0 replies.
- [PR] KAFKA-16793: Heartbeat API for upgrading ConsumerGroup [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/05/17 20:26:48 UTC, 21 replies.
- [jira] [Commented] (KAFKA-16791) Add thread detection to ClusterTestExtensions - posted by "bboyleonp (Jira)" <ji...@apache.org> on 2024/05/18 03:30:00 UTC, 0 replies.
- [PR] KAFKA-16429: Enhance all configs which can trigger rolling of new segment [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2024/05/18 09:52:34 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16786) New consumer subscribe should not require the deprecated partition.assignment.strategy - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/05/18 10:35:00 UTC, 1 replies.
- [PR] MINOR: fix incorrect formatter package in streams quickstart [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2024/05/18 15:27:22 UTC, 8 replies.
- [jira] [Assigned] (KAFKA-16791) Add thread detection to ClusterTestExtensions - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/18 18:16:00 UTC, 0 replies.
- [PR] KAFKA-16784: Migrate TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest to use ClusterTestExtensions [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/19 05:48:24 UTC, 3 replies.
- [jira] [Created] (KAFKA-16794) Can't open videos in streams documentation - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2024/05/19 08:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16795) Fix broken compatibility in kafka.tools.NoOpMessageFormatter, kafka.tools.DefaultMessageFormatter, and kafka.tools.LoggingMessageFormatter - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2024/05/19 08:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16795) Fix broken compatibility in kafka.tools.NoOpMessageFormatter, kafka.tools.DefaultMessageFormatter, and kafka.tools.LoggingMessageFormatter - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2024/05/19 09:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8206) A consumer can't discover new group coordinator when the cluster was partly restarted - posted by "Ivan Yurchenko (Jira)" <ji...@apache.org> on 2024/05/19 13:21:00 UTC, 0 replies.
- [PR] KAFKA-16541 Fix potential leader-epoch checkpoint file corruption [kafka] - posted by "ocadaruma (via GitHub)" <gi...@apache.org> on 2024/05/19 13:44:21 UTC, 8 replies.
- [jira] [Updated] (KAFKA-16796) Introduce new org.apache.kafka.tools.api.MessageParser to replace kafka.tools.DumpLogSegments.MessageParser - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/19 14:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16796) Introduce new org.apache.kafka.tools.api.MessageParser to replace kafka.tools.DumpLogSegments.MessageParser - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/19 14:31:00 UTC, 0 replies.
- [PR] MINOR: Add a constructor to accept cause in ConfigException [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/05/19 15:58:52 UTC, 8 replies.
- Re: [PR] MINOR: migrate ReassignPartitionsIntegrationTest to use ClusterTestExtensions [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/19 20:07:32 UTC, 5 replies.
- [jira] [Updated] (KAFKA-16653) Remove delayed initialization because of static voter set - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/19 20:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16797) A bit cleanup of FeatureControlManager - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/19 20:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16529) Response handling and request sending for voters RPCs - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/19 20:58:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16469) Metadata Schema Checker - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/05/19 21:02:00 UTC, 0 replies.
- [PR] KAFKA-16469: Metadata schema checker [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/05/19 21:02:15 UTC, 0 replies.
- [PR] MINOR: ensure KafkaServerTestHarness::tearDown is always invoked [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/05/19 23:52:39 UTC, 1 replies.
- [PR] KAFKA-16797: A bit cleanup of FeatureControlManager [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2024/05/19 23:57:13 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16796) Introduce new org.apache.kafka.tools.api.MessageParser to replace kafka.tools.DumpLogSegments.MessageParser - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2024/05/20 01:09:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16797) A bit cleanup of FeatureControlManager - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/20 09:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16448) Add Kafka Streams exception handler for exceptions occuring during processing (KIP-1033) - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/20 09:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16797) A bit cleanup of FeatureControlManager - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/20 09:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16544) DescribeTopicsResult#allTopicIds and DescribeTopicsResult#allTopicNames should return null instead of throwing NPE - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/20 09:21:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16796) Introduce new org.apache.kafka.tools.api.MessageParser to replace kafka.tools.DumpLogSegments.MessageParser - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/20 09:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16722) Add ConsumerGroupPartitionAssignor and ShareGroupPartitionAssignor - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/20 09:29:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16790) Calls to RemoteLogManager are made before it is configured - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/20 09:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16798) Mirrormaker2 consumer groups sync.group.offsets.interval not working - posted by "Thanos Athanasopoulos (Jira)" <ji...@apache.org> on 2024/05/20 09:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16798) Mirrormaker2 consumer groups sync.group.offsets.interval not working - posted by "Thanos Athanasopoulos (Jira)" <ji...@apache.org> on 2024/05/20 09:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16798) Mirrormaker2 dedicated mode - sync.group.offsets.interval not working - posted by "Thanos Athanasopoulos (Jira)" <ji...@apache.org> on 2024/05/20 09:49:00 UTC, 5 replies.
- [jira] [Updated] (KAFKA-16722) Add ConsumerGroupPartitionAssignor interface - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/20 10:55:00 UTC, 1 replies.
- [PR] KAFKA-16722: Introduce ConsumerGroupPartitionAssignor interface [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2024/05/20 10:59:04 UTC, 10 replies.
- Re: [PR] [Draft] KAFKA-16764: New consumer should throw InvalidTopicException on poll when invalid topic in metadata. [kafka] - posted by "appchemist (via GitHub)" <gi...@apache.org> on 2024/05/20 11:02:23 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16385) Segment is rolled before segment.ms or segment.bytes breached - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2024/05/20 12:59:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16414) Inconsistent active segment expiration behavior between retention.ms and retention.bytes - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2024/05/20 13:15:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16656) Using a custom replication.policy.separator with DefaultReplicationPolicy - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/20 13:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16603) Data loss when kafka connect sending data to Kafka - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/20 13:23:00 UTC, 0 replies.
- [PR] KAFKA-16254: Allow MM2 to fully disable offset sync feature [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/05/20 14:29:00 UTC, 17 replies.
- [jira] [Updated] (KAFKA-16254) Allow MM2 to fully disable offset sync feature - posted by "Omnia Ibrahim (Jira)" <ji...@apache.org> on 2024/05/20 14:30:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16645) CVEs in 3.7.0 docker image - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/05/20 15:00:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16692) InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when upgrading from kafka 3.5 to 3.6 - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/05/20 15:25:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-9228) Reconfigured converters and clients may not be propagated to connector tasks - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/20 16:18:00 UTC, 0 replies.
- [PR] MINOR: remove extra import from transactions tests [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/05/20 16:21:04 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-16692) InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when upgrading from kafka 3.5 to 3.6 - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/05/20 16:24:00 UTC, 0 replies.
- [PR] KAFKA-9228: Restart tasks on runtime-only connector config changes [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/05/20 16:31:03 UTC, 9 replies.
- [jira] [Updated] (KAFKA-16741) Add ShareGroupHeartbeat API support in GroupCoordinator - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/20 16:46:00 UTC, 0 replies.
- Re: [PR] KAFKA-8206: Allow client to rebootstrap [kafka] - posted by "ivanyu (via GitHub)" <gi...@apache.org> on 2024/05/20 16:53:23 UTC, 19 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 6) Post process new assignment structure [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/20 17:00:10 UTC, 2 replies.
- [PR] KIP 989 b [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2024/05/20 17:53:39 UTC, 1 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 7) Simplify requirements for rack aware graphs [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/20 17:53:55 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16272) Update connect_distributed_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/20 18:00:00 UTC, 0 replies.
- Re: [PR] KAFKA-16692: InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when upgrading from kafka [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/05/20 18:16:26 UTC, 1 replies.
- [PR] Update RemoteLogManager configuration in broker server - KAFKA-16790 [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2024/05/20 20:36:46 UTC, 24 replies.
- [jira] [Reopened] (KAFKA-16645) CVEs in 3.7.0 docker image - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/05/20 22:33:00 UTC, 0 replies.
- [PR] KAFKA-16515: Fix the ZK Metadata cache confusion between brokers and controllers [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/05/20 22:50:11 UTC, 8 replies.
- [jira] [Assigned] (KAFKA-16515) Fix the ZK Metadata cache use of voter static configuration - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/05/20 22:51:00 UTC, 0 replies.
- [PR] Bump requests from 2.24.0 to 2.32.0 in /tests [kafka] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/05/20 22:59:42 UTC, 0 replies.
- [jira] [Created] (KAFKA-16799) NetworkClientDelegate is not backing off if the node is not found - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/20 23:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16800) Resolve Gradle 9.0 deprecations - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:25:00 UTC, 0 replies.
- [PR] KAFKA-16516: Fix the controller node provider for broker to control channel [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/05/20 23:26:00 UTC, 9 replies.
- [jira] [Created] (KAFKA-16801) Streams upgrade :test target doesn't find any junit tests - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16799) NetworkClientDelegate is not backing off if the node is not found - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/20 23:29:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16802) Move build.gradle java version information inside of a java block - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16803) Upgrade to a version of ShadowJavaPlugin which doesn't use ConfigureUtil - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16804) Replace gradle archivesBaseName with archivesName - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16802) Move build.gradle java version information inside of a java block - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:45:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16804) Replace gradle archivesBaseName with archivesName - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16805) Stop using a ClosureBackedAction to configure Spotbugs reports - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16806) Explicitly declare JUnit dependencies for all test modules - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16805) Stop using a ClosureBackedAction to configure Spotbugs reports - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16803) Upgrade to a version of ShadowJavaPlugin which doesn't use ConfigureUtil - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16801) Streams upgrade :test target doesn't find any junit tests - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15494) Remove deprecated calls in build.gradle for preparing future upgrades - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/20 23:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16197) Connect Worker poll timeout prints Consumer poll timeout specific warnings. - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/21 00:01:00 UTC, 0 replies.
- [PR] Prototype: Inherit the maxParallelForks from Jenkins CPU count [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/21 00:12:30 UTC, 3 replies.
- [jira] [Commented] (KAFKA-15143) MockFixedKeyProcessorContext is missing from test-utils - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/21 01:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16794) Can't open videos in streams documentation - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/21 01:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16801) Streams upgrade :test target doesn't find any junit tests - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/21 01:22:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16666) Migrate `TransactionLogMessageFormatter`, GroupMetadataMessageFormatter` and `OffsetsMessageFormatter`to tools module - posted by "黃竣陽 (Jira)" <ji...@apache.org> on 2024/05/21 02:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16760) alterReplicaLogDirs failed even if responded with none error - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/21 02:46:00 UTC, 0 replies.
- [PR] KAFKA-16771 First log directory printed twice when formatting storage [kafka] - posted by "gongxuanzhang (via GitHub)" <gi...@apache.org> on 2024/05/21 03:14:58 UTC, 11 replies.
- Re: [PR] KAFKA-14511: extend AlterIncrementalConfigs API to support group config [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/21 03:33:44 UTC, 0 replies.
- [PR] KAFKA-16619: add log for de-novo KRaft cluster [kafka] - posted by "jayim243 (via GitHub)" <gi...@apache.org> on 2024/05/21 03:58:00 UTC, 0 replies.
- [PR] KAFKA-14934: KafkaClusterTestKit makes FaultHandler accessible [kafka] - posted by "ahmedryasser (via GitHub)" <gi...@apache.org> on 2024/05/21 04:13:25 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16794) Can't open videos in streams documentation - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/21 06:03:00 UTC, 2 replies.
- [PR] [Don't merge] Optimize heartbeat to broker test [kafka] - posted by "TaiJuWu (via GitHub)" <gi...@apache.org> on 2024/05/21 06:57:31 UTC, 0 replies.
- [PR] [draft] Debug DynamicBrokerReconfigurationTest::testTrustStoreAlter flakyness [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/05/21 07:32:04 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16757) Fix broker re-registration issues around MV 3.7-IV2 - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/05/21 08:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16757) Fix broker re-registration issues around MV 3.7-IV2 - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/05/21 08:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16800) Resolve Gradle 9.0 deprecations - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/21 08:43:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16794) Can't open videos in streams documentation - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/21 08:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16804) Replace gradle archivesBaseName with archivesName - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2024/05/21 08:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16794) Can't open videos in streams documentation - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/21 08:49:00 UTC, 0 replies.
- [PR] MINOR: fix streams_broker_compatibility test [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/05/21 08:52:30 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16804) Replace gradle archivesBaseName with archivesName - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/21 09:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16666) Migrate `TransactionLogMessageFormatter`, GroupMetadataMessageFormatter` and `OffsetsMessageFormatter`to tools module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/21 09:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15258) Consider moving MockAdminClient to the public API - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/21 11:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16802) Move build.gradle java version information inside of a java block - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/21 11:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16807) DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/21 11:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16808) Consumer join Group requests response contains 2 different members - posted by "Badhusha Muhammed (Jira)" <ji...@apache.org> on 2024/05/21 11:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16808) Consumer join Group requests response contains 2 different members - posted by "Badhusha Muhammed (Jira)" <ji...@apache.org> on 2024/05/21 11:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16808) Consumer join Group response contains 2 different members - posted by "Badhusha Muhammed (Jira)" <ji...@apache.org> on 2024/05/21 12:03:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-16802) Move build.gradle java version information inside of a java block - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/21 12:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15898) Flaky test: testFenceMultipleBrokers() – org.apache.kafka.controller.QuorumControllerTest - posted by "TaiJuWu (Jira)" <ji...@apache.org> on 2024/05/21 12:43:00 UTC, 0 replies.
- [PR] KAFKA-16804: Replace archivesBaseName with archivesName. [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2024/05/21 12:57:56 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-16707) Kafka Kraft : adding Principal Type in StandardACL for matching with KafkaPrincipal of connected client in order to defined ACL with a notion of group - posted by "Franck LEDAY (Jira)" <ji...@apache.org> on 2024/05/21 13:31:00 UTC, 0 replies.
- [PR] KAFKA-16639: AsyncKafkaConsumer#close dose not send heartbeat to leave group. [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2024/05/21 14:05:21 UTC, 26 replies.
- [jira] [Resolved] (KAFKA-16654) Refactor kafka.test.annotation.Type and ClusterTestExtensions - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/21 14:30:00 UTC, 0 replies.
- Re: [PR] KAFKA-16373: KIP-1028: Adding code to support Apache Kafka Docker Official Images [kafka] - posted by "KrishVora01 (via GitHub)" <gi...@apache.org> on 2024/05/21 14:35:21 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-16784) Migrate TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/21 14:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16807) DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions - posted by "黃竣陽 (Jira)" <ji...@apache.org> on 2024/05/21 14:51:00 UTC, 1 replies.
- Re: [PR] [WIP] KAFKA-14588 Tests for ConfigCommand of DynamicBrokerReconfigurationTest rewritten in java [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/21 14:52:22 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16807) DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/21 14:53:00 UTC, 0 replies.
- [PR] KAFKA-16666: Migrate `TransactionLogMessageFormatter`, GroupMetadataMessageFormatter` and `OffsetsMessageFormatter`to tools module [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2024/05/21 15:29:45 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7632) Support Compression Level - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/21 16:00:00 UTC, 0 replies.
- [PR] KAFKA-16795: Fix broken compatibility in kafka.tools.NoOpMessageFormatter, kafka.tools.DefaultMessageFormatter, and kafka.tools.LoggingMessageFormatter [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2024/05/21 16:08:03 UTC, 5 replies.
- Re: [PR] KAFKA-14588 ConfigCommand rewritten to java [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/21 16:21:22 UTC, 8 replies.
- [jira] [Updated] (KAFKA-16796) Introduce new org.apache.kafka.tools.api.Decoder to replace kafka.serializer.Decoder - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/21 16:43:00 UTC, 0 replies.
- [PR] [MINOR] Code Cleanup [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2024/05/21 16:50:08 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-16519) Expose the supported and finalized kraft.version in ApiVersions response - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/21 17:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16772) Introduce a type for kraft.version - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/21 17:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16578) Revert changes to connect_distributed_test.py for the new async Consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/21 17:06:00 UTC, 0 replies.
- [PR] KAFKA-16713: Define initial set of RPCs for KIP-932 [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2024/05/21 17:09:22 UTC, 8 replies.
- [jira] [Commented] (KAFKA-16796) Introduce new org.apache.kafka.tools.api.Decoder to replace kafka.serializer.Decoder - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/21 17:10:00 UTC, 1 replies.
- [PR] MINOR: Move Throttler to storage module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/21 17:26:06 UTC, 4 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 8) Added TopicPartitionAssignmentInfo [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/21 18:13:21 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-15258) Consider moving MockAdminClient to the public API - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/21 18:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15242) FixedKeyProcessor testing is unusable - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/21 18:32:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14517) Implement regex subscriptions - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/21 19:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16586) Test TaskAssignorConvergenceTest failing - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/05/21 19:20:00 UTC, 3 replies.
- Re: [PR] KAFKA-16343: Add unit tests of foreignKeyJoin classes [kafka] - posted by "wcarlson5 (via GitHub)" <gi...@apache.org> on 2024/05/21 19:22:35 UTC, 1 replies.
- [jira] [Created] (KAFKA-16809) Run javadoc build in CI - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/21 19:57:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16001) Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder - posted by "Brenden DeLuna (Jira)" <ji...@apache.org> on 2024/05/21 20:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16001) Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/21 20:45:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16000) Migrate MembershipManagerImplTest away from ConsumerTestBuilder - posted by "Brenden DeLuna (Jira)" <ji...@apache.org> on 2024/05/21 20:47:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15999) Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder - posted by "Brenden DeLuna (Jira)" <ji...@apache.org> on 2024/05/21 20:47:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16557) Fix OffsetFetchRequestState.toString() - posted by "Brenden DeLuna (Jira)" <ji...@apache.org> on 2024/05/21 20:47:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16558) Implement HeartbeatRequestState.toStringBase() - posted by "Brenden DeLuna (Jira)" <ji...@apache.org> on 2024/05/21 20:47:00 UTC, 0 replies.
- [PR] KAFKA-16809: Run Javadoc in CI [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/21 21:00:47 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16779) Kafka retains logs past specified retention - posted by "Nicholas Feinberg (Jira)" <ji...@apache.org> on 2024/05/21 21:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16798) Mirrormaker2 dedicated mode - sync.group.offsets.interval not working - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/21 23:50:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-16662) UnwritableMetadataException: Metadata has been lost - posted by "Jianbin Chen (Jira)" <ji...@apache.org> on 2024/05/22 03:04:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-16662) UnwritableMetadataException: Metadata has been lost - posted by "Jianbin Chen (Jira)" <ji...@apache.org> on 2024/05/22 03:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16783) Migrate RemoteLogMetadataManagerTest to new test infra - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/22 03:29:00 UTC, 0 replies.
- [PR] MINOR: Aesthetic, Uniformity Changes and Reducing warnings [kafka] - posted by "rreddy-22 (via GitHub)" <gi...@apache.org> on 2024/05/22 04:27:37 UTC, 2 replies.
- [jira] [Created] (KAFKA-16810) Improve kafka-consumer-perf-test to benchmark single partition - posted by "Harsh Panchal (Jira)" <ji...@apache.org> on 2024/05/22 06:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16810) Improve kafka-consumer-perf-test to benchmark single partition - posted by "Harsh Panchal (Jira)" <ji...@apache.org> on 2024/05/22 06:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16807) DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/22 06:47:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16811) Punctuate Ratio metric almost impossible to track - posted by "Sebastien Viale (Jira)" <ji...@apache.org> on 2024/05/22 06:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16586) Test TaskAssignorConvergenceTest failing - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/22 07:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16812) The tools-related tests are slow - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/22 08:16:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16812) The tools-related tests are slow - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/22 08:16:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16798) Mirrormaker2 dedicated mode - sync.group.offsets.interval not working - posted by "Thanos Athanasopoulos (Jira)" <ji...@apache.org> on 2024/05/22 08:29:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-15513) KRaft cluster fails with SCRAM authentication enabled for control-plane - posted by "Edgar (Jira)" <ji...@apache.org> on 2024/05/22 08:39:00 UTC, 0 replies.
- [PR] KAFKA-16373: KIP-1028: Adding code to support Apache Kafka Docker Official Images [kafka] - posted by "KrishVora01 (via GitHub)" <gi...@apache.org> on 2024/05/22 09:03:45 UTC, 13 replies.
- [jira] [Created] (KAFKA-16813) Add global timeout for "@Test" and "@TestTemplate" - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/22 09:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16622) Mirromaker2 first Checkpoint not emitted until consumer group fully catches up once - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/22 09:17:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15905) Restarts of MirrorCheckpointTask should not permanently interrupt offset translation - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/22 09:18:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15905) Restarts of MirrorCheckpointTask should not permanently interrupt offset translation - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/22 09:19:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16622) Mirromaker2 first Checkpoint not emitted until consumer group fully catches up once - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/22 09:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16641) MM2 offset translation should interpolate between sparse OffsetSyncs - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/22 11:19:00 UTC, 1 replies.
- Re: [PR] KAFKA-14587: Move AclCommand to tools [WIP] [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/22 11:33:22 UTC, 0 replies.
- [jira] [Created] (KAFKA-16814) KRaft broker cannot startup when `partition.metadata` is missing - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/22 11:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16814) KRaft broker cannot startup when `partition.metadata` is missing - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/22 11:58:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-16814) KRaft broker cannot startup when `partition.metadata` is missing - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/22 12:01:00 UTC, 7 replies.
- [PR] KAFKA-15541: Add iterator-duration metrics [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2024/05/22 12:27:11 UTC, 3 replies.
- [PR] MINOR: Move parseCsvList to Csv in server-common [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/22 12:44:38 UTC, 2 replies.
- [jira] [Created] (KAFKA-16815) Handle FencedInstanceId on heartbeat for new consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/22 13:50:00 UTC, 0 replies.
- [PR] [Draft]Add concurrent by Junit5 [kafka] - posted by "TaiJuWu (via GitHub)" <gi...@apache.org> on 2024/05/22 14:48:02 UTC, 1 replies.
- [jira] [Created] (KAFKA-16816) Remove unneeded FencedInstanceId support on commit path for new consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/22 14:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16817) FK Join Response topic can be lower volume - posted by "John Roesler (Jira)" <ji...@apache.org> on 2024/05/22 15:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15041) Source Connector auto topic creation fails when topic is deleted and brokers don't support auto topic creation - posted by "Sagar Rao (Jira)" <ji...@apache.org> on 2024/05/22 16:38:00 UTC, 0 replies.
- Re: [PR] KAFKA-16764: New consumer should throw InvalidTopicException on poll when invalid topic in metadata [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/05/22 16:39:22 UTC, 18 replies.
- [jira] [Updated] (KAFKA-16818) Move event processing-related tests from ConsumerNetworkThreadTest to ApplicationEventProcessorTest - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/22 16:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16818) Move event-processing tests from ConsumerNetworkThreadTest to ApplicationEventProcessorTest - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/22 16:52:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-12399) Deprecate Log4J Appender KIP-719 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/22 16:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-12399) Deprecate Log4J Appender KIP-719 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/22 16:55:00 UTC, 0 replies.
- [PR] KAFKA-16200: Enforce that RequestManager implementations respect user-provided timeout [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/05/22 17:18:28 UTC, 16 replies.
- [jira] [Commented] (KAFKA-16817) FK Join Response topic can be lower volume - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/22 17:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16817) FK Join Response topic can be lower volume - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/22 17:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16819) CoordinatorRequestManager seems to return 0ms during the coordinator discovery - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/22 18:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15250) ConsumerNetworkThread is running tight loop - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/22 18:10:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15250) ConsumerNetworkThread is running tight loop - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/22 18:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16820) Kafka Broker fails to connect to Kraft Controller with no DNS matching - posted by "Arushi Helms (Jira)" <ji...@apache.org> on 2024/05/22 18:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16820) Kafka Broker fails to connect to Kraft Controller with no DNS matching - posted by "Arushi Helms (Jira)" <ji...@apache.org> on 2024/05/22 18:31:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-16821) Create a new interface to store member metadata - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2024/05/22 18:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16822) Abstract consumer group in coordinator to share functionality with share group - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/05/22 19:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16819) CoordinatorRequestManager seems to return 0ms during the coordinator discovery - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/22 20:17:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16823) Extract LegacyConsumer-specific unit tests from generic KafkaConsumerTest - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/22 20:42:00 UTC, 0 replies.
- [PR] KAFKA-16737: Enable unit tests for new consumer & cleanup TODOs [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/05/22 20:58:36 UTC, 5 replies.
- [jira] [Created] (KAFKA-16824) Utils.getHost and Utils.getPort do not catch a lot of invalid host and ports - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/22 21:00:00 UTC, 0 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 9) TaskAssignmentUtils implementation of optimizeRackAwareActiveTasks [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/22 21:01:20 UTC, 24 replies.
- [jira] [Assigned] (KAFKA-16623) KafkaAsyncConsumer system tests warn about revoking partitions that weren't previously assigned - posted by "Jon Chiu (Jira)" <ji...@apache.org> on 2024/05/22 21:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop - posted by "Jon Chiu (Jira)" <ji...@apache.org> on 2024/05/22 21:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/22 21:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/05/22 21:22:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16815) Handle FencedInstanceId on heartbeat for new consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/22 21:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15284) Implement ConsumerGroupProtocolVersionResolver to determine consumer group protocol - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/22 22:12:00 UTC, 0 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 10) Topic partition rack annotation simplified [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/22 22:48:48 UTC, 4 replies.
- [jira] [Updated] (KAFKA-15630) Improve documentation of offset.lag.max - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/22 23:19:00 UTC, 1 replies.
- Re: [PR] KAFKA-5072[WIP]: Kafka topics should allow custom metadata configs within some config namespace [kafka] - posted by "andreyolv (via GitHub)" <gi...@apache.org> on 2024/05/23 00:43:45 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16811) Punctuate Ratio metric almost impossible to track - posted by "Rohan Desai (Jira)" <ji...@apache.org> on 2024/05/23 03:01:00 UTC, 2 replies.
- Re: [PR] KAFKA-14412: Add statestore.uncommitted.max.bytes [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/23 03:33:11 UTC, 0 replies.
- [PR] Improve logical type compatibility in SchemaProjector [kafka] - posted by "fanyang (via GitHub)" <gi...@apache.org> on 2024/05/23 05:29:38 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16820) Kafka Broker fails to connect to Kraft Controller with no DNS matching - posted by "Vikash Mishra (Jira)" <ji...@apache.org> on 2024/05/23 05:42:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-16257) SchemaProjector should be extensible to logical types - posted by "Fan Yang (Jira)" <ji...@apache.org> on 2024/05/23 05:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16825) CVE vulnerabilities in Jetty and netty - posted by "mooner (Jira)" <ji...@apache.org> on 2024/05/23 06:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16793) Heartbeat API for upgrading ConsumerGroup - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/23 06:28:00 UTC, 0 replies.
- Re: [PR] KAFKA-15853: Move KafkaConfig properties definition out of core [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/05/23 06:56:34 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16518) Storage tool changes for KIP-853 - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/23 07:05:00 UTC, 9 replies.
- [jira] [Comment Edited] (KAFKA-16518) Storage tool changes for KIP-853 - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/23 07:09:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16518) Storage tool changes for KIP-853 - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/23 07:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16257) SchemaProjector should be extensible to logical types - posted by "Fan Yang (Jira)" <ji...@apache.org> on 2024/05/23 07:24:00 UTC, 0 replies.
- [PR] KAFKA-15853 Move DelegationConfigs from KafkaConfig [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/05/23 07:32:08 UTC, 3 replies.
- [PR] KAFKA-15853 Move ControlledShutdownConfigs from KafkaConfig [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/05/23 07:59:59 UTC, 3 replies.
- [jira] [Updated] (KAFKA-16826) Integrate Native Kafka Docker Image with github Actions - posted by "Krishna Agarwal (Jira)" <ji...@apache.org> on 2024/05/23 09:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16826) Integrate Native Kafka Docker Image with github Actions - posted by "Krishna Agarwal (Jira)" <ji...@apache.org> on 2024/05/23 09:26:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16825) CVE vulnerabilities in Jetty and netty - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/23 09:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16827) Integrate Native Apache Kafka with vagrant System tests - posted by "Krishna Agarwal (Jira)" <ji...@apache.org> on 2024/05/23 09:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16827) Integrate Native Apache Kafka with vagrant System tests - posted by "Krishna Agarwal (Jira)" <ji...@apache.org> on 2024/05/23 09:31:00 UTC, 0 replies.
- [PR] KAFKA-16825: Update netty/jetty/jackson/zstd dependencies [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/23 09:40:52 UTC, 2 replies.
- Re: [PR] KAFKA-13403 Fix KafkaServer crashes when deleting topics due to the race in log deletion [kafka] - posted by "ocadaruma (via GitHub)" <gi...@apache.org> on 2024/05/23 10:24:54 UTC, 0 replies.
- Re: [PR] KAFKA-16372 Fix producer doc discrepancy with the exception behavior [kafka] - posted by "ocadaruma (via GitHub)" <gi...@apache.org> on 2024/05/23 10:25:58 UTC, 0 replies.
- [PR] Update dependencies [kafka] - posted by "highbolder (via GitHub)" <gi...@apache.org> on 2024/05/23 11:15:56 UTC, 1 replies.
- [PR] KAFKA-15853: Move general configs out of KafkaConfig [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/05/23 11:28:13 UTC, 15 replies.
- [jira] [Comment Edited] (KAFKA-16641) MM2 offset translation should interpolate between sparse OffsetSyncs - posted by "Adrian Preston (Jira)" <ji...@apache.org> on 2024/05/23 11:39:00 UTC, 0 replies.
- [PR] KAFKA-15541: Add oldest-iterator-open-since-ms metric [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2024/05/23 11:50:25 UTC, 17 replies.
- [jira] [Commented] (KAFKA-16824) Utils.getHost and Utils.getPort do not catch a lot of invalid host and ports - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2024/05/23 12:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16824) Utils.getHost and Utils.getPort do not catch a lot of invalid host and ports - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/23 12:06:00 UTC, 0 replies.
- Re: [PR] KAFKA-15931: Reopen TransactionIndex if channel is closed [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/05/23 12:16:44 UTC, 2 replies.
- [jira] [Created] (KAFKA-16828) RackAwareTaskAssignorTest failed - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/23 12:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16829) Consider removing delegation.token.master.key - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/23 12:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16829) Consider removing delegation.token.master.key - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/23 12:26:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16828) RackAwareTaskAssignorTest failed - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2024/05/23 12:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-12601) Remove deprecated `delegation.token.master.key` - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/23 12:32:00 UTC, 6 replies.
- [PR] KAFKA-16807: DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2024/05/23 12:33:56 UTC, 16 replies.
- [jira] [Commented] (KAFKA-14482) Move LogLoader to storage module - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2024/05/23 13:03:00 UTC, 0 replies.
- [PR] KAFKA-16828: RackAwareTaskAssignorTest failed [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2024/05/23 13:17:45 UTC, 4 replies.
- Re: [PR] KAFKA-16371: fix lingering pending commit when handling OFFSET_METADATA_TOO_LARGE [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/23 13:18:48 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-16521) kafka-metadata-quorum describe changes for KIP-853 - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2024/05/23 13:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16520) Changes to DescribeQuorum response - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2024/05/23 13:20:00 UTC, 3 replies.
- [PR] KAFKA-16826: Integrate Native Docker Image with github actions [kafka] - posted by "kagarwal06 (via GitHub)" <gi...@apache.org> on 2024/05/23 13:30:15 UTC, 7 replies.
- [jira] [Updated] (KAFKA-16521) kafka-metadata-quorum describe changes for KIP-853 - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2024/05/23 13:37:00 UTC, 0 replies.
- [PR] KAFKA-16827: Integrate kafka native-image with system tests [kafka] - posted by "kagarwal06 (via GitHub)" <gi...@apache.org> on 2024/05/23 13:43:38 UTC, 14 replies.
- [PR] KAFKA-16815: Handle FencedInstanceId in HB response [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/05/23 14:27:54 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-16521) kafka-metadata-quorum describe changes for KIP-853 - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2024/05/23 14:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16521) kafka-metadata-quorum describe changes for KIP-853 - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2024/05/23 14:33:00 UTC, 1 replies.
- [PR] KAFKA-16824: Utils.getHost and Utils.getPort do not catch a lot of invalid host and ports. [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2024/05/23 14:33:07 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-16825) CVE vulnerabilities in Jetty and netty - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/23 15:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16825) CVE vulnerabilities in Jetty and netty - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/23 15:23:00 UTC, 0 replies.
- [PR] [MINOR] Code Cleanup (Clients Module) [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2024/05/23 16:13:03 UTC, 4 replies.
- [jira] [Reopened] (KAFKA-15905) Restarts of MirrorCheckpointTask should not permanently interrupt offset translation - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/23 16:26:00 UTC, 0 replies.
- [PR] [MINOR] Code Cleanup - Streams [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2024/05/23 16:54:49 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16530) Fix high-watermark calculation to not assume the leader is in the voter set - posted by "Alyssa Huang (Jira)" <ji...@apache.org> on 2024/05/23 18:14:00 UTC, 0 replies.
- [PR] MINOR: Disable JDK 11 and 17 builds on PRs [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/23 18:16:12 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16766) New consumer offsetsForTimes timeout exception does not have the proper message - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/23 18:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16766) New consumer offsetsForTimes timeout exception has wrong message - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/23 18:29:00 UTC, 0 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 11) Implemented StickyTaskAssignor [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/23 18:37:07 UTC, 10 replies.
- [jira] [Resolved] (KAFKA-16795) Fix broken compatibility in kafka.tools.NoOpMessageFormatter, kafka.tools.DefaultMessageFormatter, and kafka.tools.LoggingMessageFormatter - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/23 18:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16830) Remove the scala version formatters support - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/23 18:54:00 UTC, 0 replies.
- [PR] KAFKA-16822: Abstract consumer group to share functionality with share group [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2024/05/23 19:12:42 UTC, 1 replies.
- [jira] [Created] (KAFKA-16831) CoordinatorRuntime should initialize MemoryRecordsBuilder with max batch size write limit - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/05/23 19:17:00 UTC, 0 replies.
- [PR] Revert "KAFKA-15045: (KIP-924 pt. 10) Topic partition rack annotation simplified (#16034)" [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/05/23 19:49:50 UTC, 2 replies.
- Re: [PR] MINOR: KIP-848 Uniform Assignor Bugs [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/23 19:51:06 UTC, 1 replies.
- [PR] KAFKA-15045: Fix RackAwareTaskAssignorTest [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/23 20:31:25 UTC, 2 replies.
- [jira] [Created] (KAFKA-16832) LeaveGroup API for upgrading ConsumerGroup - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/05/23 20:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16832) LeaveGroup API for upgrading ConsumerGroup - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/05/23 20:50:00 UTC, 0 replies.
- [PR] KAFKA-16832: LeaveGroup API for upgrading ConsumerGroup [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/05/23 20:52:04 UTC, 19 replies.
- [PR] KAFKA-16535: Implement AddVoter, RemoveVoter, UpdateVoter RPCs [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/05/23 20:53:54 UTC, 1 replies.
- [PR] KAFKA-16831: CoordinatorRuntime should initialize MemoryRecordsBuilder with max batch size write limit [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/05/23 20:55:26 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16516) Fix the controller node provider for broker to control channel - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/05/23 20:57:00 UTC, 0 replies.
- Re: [PR] MINOR: Disable JDK 11 and 17 tests on PRs [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2024/05/23 21:03:11 UTC, 15 replies.
- [jira] [Commented] (KAFKA-16530) Fix high-watermark calculation to not assume the leader is in the voter set - posted by "Alyssa Huang (Jira)" <ji...@apache.org> on 2024/05/23 21:12:00 UTC, 3 replies.
- [PR] MINOR: log coordinator event errors [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/05/23 21:15:36 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15630) Improve documentation of offset.lag.max - posted by "Ganesh Sadanala (Jira)" <ji...@apache.org> on 2024/05/23 21:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16828) RackAwareTaskAssignorTest failed - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/23 21:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16833) PartitionInfo missing equals and hashCode methods - posted by "Alyssa Huang (Jira)" <ji...@apache.org> on 2024/05/23 22:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16833) Cluster missing topicIds from equals and hashCode, PartitionInfo missing equals and hashCode - posted by "Alyssa Huang (Jira)" <ji...@apache.org> on 2024/05/23 22:59:00 UTC, 0 replies.
- [PR] return to commit f9db4fa19cce975a6bbaeb09fbe9c91b81846b5a [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/05/23 23:12:40 UTC, 1 replies.
- [PR] KAFKA-16833: Fixing PartitionInfo and Cluster equals and hashCode [kafka] - posted by "ahuang98 (via GitHub)" <gi...@apache.org> on 2024/05/23 23:27:52 UTC, 8 replies.
- [jira] [Commented] (KAFKA-16583) Update from 3.4.0 to 3.7.0 image write failed in Kraft mode - posted by "Jianbin Chen (Jira)" <ji...@apache.org> on 2024/05/24 03:03:00 UTC, 1 replies.
- Re: [PR] ConfigRegistry [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/24 03:33:02 UTC, 0 replies.
- Re: [PR] KAFKA-16583: fix PartitionRegistration#toRecord directory check under metadata version 3_7_IV2 [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/05/24 03:36:01 UTC, 6 replies.
- [jira] [Updated] (KAFKA-16583) Update from 3.4.0 to 3.7.0 image write failed in Kraft mode - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/24 03:38:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16834) add PartitionRegistration#toRecord loss info - posted by "Jianbin Chen (Jira)" <ji...@apache.org> on 2024/05/24 03:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16834) add the reason for the failure of PartitionRegistration#toRecord - posted by "Jianbin Chen (Jira)" <ji...@apache.org> on 2024/05/24 03:41:00 UTC, 1 replies.
- [PR] KAFKA-16834: add the reason for the failure of PartitionRegistration#toRecord [kafka] - posted by "funky-eyes (via GitHub)" <gi...@apache.org> on 2024/05/24 03:41:05 UTC, 0 replies.
- [PR] KAFKA-16796: Introduce new org.apache.kafka.tools.api.Decoder to replace kafka.serializer.Decoder [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/24 04:41:36 UTC, 4 replies.
- [PR] [MINOR]: Code Cleanup - Metadata module [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2024/05/24 05:47:26 UTC, 1 replies.
- [PR] [MINOR] Code Cleanup - Connect Module [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2024/05/24 06:04:19 UTC, 1 replies.
- [PR] [MINOR] : Code Cleanup - Misc modules [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2024/05/24 06:37:47 UTC, 3 replies.
- [jira] [Created] (KAFKA-16835) Add Support for consumer to read in commit order. - posted by "Manjunath (Jira)" <ji...@apache.org> on 2024/05/24 06:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16826) Integrate Native Kafka Docker Image with github Actions - posted by "Manikumar (Jira)" <ji...@apache.org> on 2024/05/24 06:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16836) Suspend reason of standby update listener is not correct - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/05/24 07:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16520) Changes to DescribeQuorum response - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2024/05/24 07:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16798) Mirrormaker2 dedicated mode - sync.group.offsets.interval not working - posted by "Thanos Athanasopoulos (Jira)" <ji...@apache.org> on 2024/05/24 07:41:00 UTC, 0 replies.
- Re: [PR] KAFKA-16822: Abstract consumer group to share functionality with share group (KIP-932) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/24 07:46:44 UTC, 16 replies.
- [jira] [Resolved] (KAFKA-16626) Uuid to String for subscribed topic names in assignment spec - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/24 07:53:00 UTC, 0 replies.
- [PR] KAFKA:16821 - Member subscription spec interface [kafka] - posted by "rreddy-22 (via GitHub)" <gi...@apache.org> on 2024/05/24 08:03:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16835) Add Support for consumer to read in commit order. - posted by "Manjunath (Jira)" <ji...@apache.org> on 2024/05/24 09:07:00 UTC, 1 replies.
- [PR] Adding standalone parameter to kafka-storage.sh [KAFKA-16518] [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2024/05/24 09:40:29 UTC, 2 replies.
- [PR] MINOR: mention KAFKA-15905 in docs "Notable changes in 3.7.1" [kafka] - posted by "edoardocomar (via GitHub)" <gi...@apache.org> on 2024/05/24 10:57:30 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-16815) Handle FencedInstanceId on heartbeat for new consumer - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/24 12:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16837) Kafka Connect fails on update connector for incorrect previous Config Provider tasks - posted by "Sergey Ivanov (Jira)" <ji...@apache.org> on 2024/05/24 12:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16837) Kafka Connect fails on update connector for incorrect previous Config Provider tasks - posted by "Sergey Ivanov (Jira)" <ji...@apache.org> on 2024/05/24 12:35:00 UTC, 2 replies.
- [PR] [WIP] KAFKA-15265: Integrate RLMQuotaManager for throttling fetches from remote storage [kafka] - posted by "abhijeetk88 (via GitHub)" <gi...@apache.org> on 2024/05/24 12:50:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-16838) Kafka Connect loads old tasks from removed connectors - posted by "Sergey Ivanov (Jira)" <ji...@apache.org> on 2024/05/24 12:52:00 UTC, 0 replies.
- [PR] KAFKA-16371; fix lingering pending commit when handling OFFSET_METADATA_TOO_LARGE [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/24 12:52:52 UTC, 19 replies.
- [jira] [Updated] (KAFKA-16838) Kafka Connect loads old tasks from removed connectors - posted by "Sergey Ivanov (Jira)" <ji...@apache.org> on 2024/05/24 12:57:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-10234) The key/value deserializer used by ConsoleConsumer is not closed - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/24 13:13:00 UTC, 0 replies.
- Re: [PR] KAFKA-16821: Member Subscription Spec Interface [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/24 13:13:11 UTC, 24 replies.
- [jira] [Assigned] (KAFKA-16503) getOrMaybeCreateClassicGroup should not thrown GroupIdNotFoundException - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/24 14:33:00 UTC, 0 replies.
- [PR] KAFKA-16503; getOrMaybeCreateClassicGroup should not thrown GroupIdNotFoundException [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/24 14:50:43 UTC, 1 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 13) Wiring in new assignment configs and logic [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/24 16:15:40 UTC, 7 replies.
- [PR] Improve producer ID expiration performance [kafka] - posted by "CalvinConfluent (via GitHub)" <gi...@apache.org> on 2024/05/24 17:12:53 UTC, 6 replies.
- [PR] KAFKA-15541: Use LongAdder instead of AtomicInteger [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2024/05/24 18:34:04 UTC, 2 replies.
- [PR] KAFKA-15743: Fix the directory UUIDs in ReplicationQuotasTest [kafka] - posted by "wernerdv (via GitHub)" <gi...@apache.org> on 2024/05/24 19:13:54 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15743) KRaft support in ReplicationQuotasTest - posted by "Dmitry Werner (Jira)" <ji...@apache.org> on 2024/05/24 19:16:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15743) KRaft support in ReplicationQuotasTest - posted by "Dmitry Werner (Jira)" <ji...@apache.org> on 2024/05/24 19:17:00 UTC, 3 replies.
- [PR] [WIP] KAFKA-15265: Dynamic broker configs for remote fetch/copy quotas [kafka] - posted by "abhijeetk88 (via GitHub)" <gi...@apache.org> on 2024/05/24 19:46:55 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16831) CoordinatorRuntime should initialize MemoryRecordsBuilder with max batch size write limit - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/24 20:35:00 UTC, 0 replies.
- Re: [PR] KAFKA-16257: Improve logical type compatibility in SchemaProjector [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/24 21:05:45 UTC, 2 replies.
- [PR] KAFKA-16530: Fix high-watermark calculation to not assume the leader is in the voter set [kafka] - posted by "ahuang98 (via GitHub)" <gi...@apache.org> on 2024/05/24 21:57:08 UTC, 6 replies.
- [jira] [Created] (KAFKA-16839) Replace KafkaRaftClient's voterNode with leadeNode - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/24 22:00:00 UTC, 0 replies.
- [PR] KAFKA-15630 Improve documentation of offset.lag.max [kafka] - posted by "ganesh-sadanala (via GitHub)" <gi...@apache.org> on 2024/05/24 22:31:10 UTC, 3 replies.
- Re: [PR] Kafka-16540: Update partitions if min isr config is changed. [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/05/24 23:49:17 UTC, 7 replies.
- [jira] [Created] (KAFKA-16840) Add a --timeout option to ConfigCommand - posted by "Vishal Palla (Jira)" <ji...@apache.org> on 2024/05/25 00:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15203) Remove dependency on Reflections - posted by "Ganesh Sadanala (Jira)" <ji...@apache.org> on 2024/05/25 01:06:00 UTC, 21 replies.
- Re: [PR] KAFKA-15045: (KIP-924 pt. 12) Wiring in new assignment configs and logic [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/05/25 06:51:24 UTC, 6 replies.
- [jira] [Commented] (KAFKA-16805) Stop using a ClosureBackedAction to configure Spotbugs reports - posted by "黃竣陽 (Jira)" <ji...@apache.org> on 2024/05/25 08:22:00 UTC, 3 replies.
- [PR] KAFKA-16805: Stop using a ClosureBackedAction to configure Spotbugs reports [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2024/05/25 08:25:45 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-16805) Stop using a ClosureBackedAction to configure Spotbugs reports - posted by "黃竣陽 (Jira)" <ji...@apache.org> on 2024/05/25 13:09:00 UTC, 0 replies.
- Re: [PR] [Don't merge]KAFKA-16812: The tools-related tests are slow [kafka] - posted by "TaiJuWu (via GitHub)" <gi...@apache.org> on 2024/05/25 14:20:11 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-16687) Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0 - posted by "FTR (Jira)" <ji...@apache.org> on 2024/05/25 14:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16841) ZKIntegrationTests broken - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/05/25 15:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16841) ZKMigrationIntegrationTests broken - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/05/25 15:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16841) ZKMigratoinIntegrationTests broken - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/05/25 15:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16841) ZKMigrationIntegrationTests broken - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/05/25 15:53:00 UTC, 2 replies.
- [PR] Revert "KAFKA-16515: Fix the ZK Metadata cache confusion between brokers and controllers [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/05/25 15:57:19 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-16625) Reverse Lookup Partition to Member in Assignors - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/25 16:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16824) Utils.getHost and Utils.getPort do not catch a lot of invalid host and ports - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/25 23:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16842) Make sure to validate controller.quorum.bootstrap.server - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/25 23:56:00 UTC, 0 replies.
- [PR] MINOR:Modify ConsumerRebalanceListener doc [kafka] - posted by "TaiJuWu (via GitHub)" <gi...@apache.org> on 2024/05/26 07:37:01 UTC, 0 replies.
- Re: [PR] MINOR:Improve ConsumerRebalanceListener doc [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/26 13:34:52 UTC, 12 replies.
- [PR] KAFKA-16414: Inconsistent active segment expiration behavior between retention.ms and retention.bytes [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2024/05/26 15:20:07 UTC, 0 replies.
- [PR] MINOR: Add more unit tests to LogSegments [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2024/05/26 17:27:51 UTC, 10 replies.
- [jira] [Assigned] (KAFKA-15203) Remove dependency on Reflections - posted by "Ganesh Sadanala (Jira)" <ji...@apache.org> on 2024/05/26 18:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16843) Remove preAppendErrors from createPutCacheCallback - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/26 20:53:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16805) Stop using a ClosureBackedAction to configure Spotbugs reports - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/26 21:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16804) Replace gradle archivesBaseName with archivesName - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/26 21:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15203) Remove dependency on Reflections - posted by "Ganesh Sadanala (Jira)" <ji...@apache.org> on 2024/05/27 01:02:00 UTC, 8 replies.
- [PR] KAFKA-15265: Remote copy throttle metrics [kafka] - posted by "abhijeetk88 (via GitHub)" <gi...@apache.org> on 2024/05/27 06:07:45 UTC, 0 replies.
- [PR] KAFKA-15265: Remote fetch throttle metrics [kafka] - posted by "abhijeetk88 (via GitHub)" <gi...@apache.org> on 2024/05/27 08:29:54 UTC, 0 replies.
- [jira] [Created] (KAFKA-16844) ByteArrayConverter can't convert ByteBuffer - posted by "Fan Yang (Jira)" <ji...@apache.org> on 2024/05/27 08:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16845) Migrate ReplicationQuotasTestRig to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/27 09:22:00 UTC, 0 replies.
- Re: [PR] KAFKA-15265: Integrate RLMQuotaManager for throttling copies to remote storage [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/05/27 09:35:23 UTC, 27 replies.
- [jira] [Updated] (KAFKA-16452) Bound highwatermark offset to range b/w local-log-start-offset and log-end-offset - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/27 09:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16531) Fix check-quorum calculation to not assume that the leader is in the voter set - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/27 09:47:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16531) Fix check-quorum calculation to not assume that the leader is in the voter set - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/27 09:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16780) Txn consumer exerts pressure on remote storage when reading non-txn topic - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2024/05/27 10:52:00 UTC, 0 replies.
- [PR] MINOR: Optimize uniform (homogenous) assignor [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/27 11:37:27 UTC, 42 replies.
- [jira] [Created] (KAFKA-16846) Should TxnOffsetCommit API fail all the offsets if any fails the validation? - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/27 12:02:00 UTC, 0 replies.
- [PR] MINOR: Log client idle disconnect events at DEBUG level [kafka] - posted by "nicolasguyomar (via GitHub)" <gi...@apache.org> on 2024/05/27 13:11:16 UTC, 0 replies.
- [PR] KAFKA-16448: Add ProcessingExceptionHandler interface and implementations [kafka] - posted by "loicgreffier (via GitHub)" <gi...@apache.org> on 2024/05/27 13:30:40 UTC, 13 replies.
- [jira] [Commented] (KAFKA-14588) Move ConfigCommand to tools - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2024/05/27 14:01:00 UTC, 0 replies.
- [PR] KAFKA-14094 KIP-853 Changes to DescribeQuorum request/response [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/05/27 14:25:32 UTC, 2 replies.
- [PR] KAFKA-16448: Add ProcessingExceptionHandler in Streams configuration [kafka] - posted by "loicgreffier (via GitHub)" <gi...@apache.org> on 2024/05/27 15:11:35 UTC, 7 replies.
- [jira] [Resolved] (KAFKA-16371) Unstable committed offsets after triggering commits where metadata for some partitions are over the limit - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/27 15:14:00 UTC, 0 replies.
- [PR] KAFKA-16448: Catch and handle processing exceptions [kafka] - posted by "loicgreffier (via GitHub)" <gi...@apache.org> on 2024/05/27 15:15:38 UTC, 21 replies.
- [jira] [Updated] (KAFKA-15203) Remove dependency on Reflections - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/27 15:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-12708) Rewrite org.apache.kafka.test.Microbenchmarks by JMH - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2024/05/27 16:12:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16841) ZKMigrationIntegrationTests broken - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/05/27 16:38:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-12708) Rewrite org.apache.kafka.test.Microbenchmarks by JMH - posted by "GeordieMai (Jira)" <ji...@apache.org> on 2024/05/27 17:13:00 UTC, 0 replies.
- [PR] Adding standalone argument for storage [kafka-16518] [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2024/05/27 17:16:45 UTC, 2 replies.
- [jira] (KAFKA-16518) Storage tool changes for KIP-853 - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/27 17:26:00 UTC, 0 replies.
- [PR] KAFKA-16788 - Fix resource leakage during connector start() failure [kafka] - posted by "ashoke-cube (via GitHub)" <gi...@apache.org> on 2024/05/27 17:44:55 UTC, 1 replies.
- [jira] [Closed] (KAFKA-16675) Move rebalance callback test for positions to callbacks test file - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/27 18:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15283) Client support for OffsetFetch and OffsetCommit with topic ID - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/27 18:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16418) Review/split long-running admin client integration tests - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/27 19:29:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-16418) Review/split long-running admin client integration tests - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/27 19:30:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16418) Review/split long-running admin client integration tests - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/27 19:30:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16418) Review/split long-running admin client integration tests - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/27 19:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16527) Update to existing KRaft RPCs and request handling - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/27 20:10:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16803) Upgrade to a version of ShadowJavaPlugin which doesn't use ConfigureUtil - posted by "Eric Lu (Jira)" <ji...@apache.org> on 2024/05/27 21:57:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-16803) Upgrade to a version of ShadowJavaPlugin which doesn't use ConfigureUtil - posted by "Eric Lu (Jira)" <ji...@apache.org> on 2024/05/27 23:03:00 UTC, 2 replies.
- [PR] bumping shadowJar 8.1.0->8.1.1 [kafka] - posted by "EricLuGHub (via GitHub)" <gi...@apache.org> on 2024/05/27 23:05:30 UTC, 5 replies.
- [jira] [Commented] (KAFKA-16844) ByteArrayConverter can't convert ByteBuffer - posted by "Arnav Dadarya (Jira)" <ji...@apache.org> on 2024/05/27 23:31:00 UTC, 1 replies.
- [jira] (KAFKA-15203) Remove dependency on Reflections - posted by "Ganesh Sadanala (Jira)" <ji...@apache.org> on 2024/05/28 00:21:00 UTC, 0 replies.
- [PR] KAFKA-10787: Add import ordering checkstyle rule and configure an automatic formatter [kafka] - posted by "gongxuanzhang (via GitHub)" <gi...@apache.org> on 2024/05/28 03:12:43 UTC, 12 replies.
- [jira] [Resolved] (KAFKA-16709) alter logDir within broker might cause log cleanup hanging - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/28 04:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16843) Remove preAppendErrors from createPutCacheCallback - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2024/05/28 05:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16844) ByteArrayConverter can't convert ByteBuffer - posted by "Fan Yang (Jira)" <ji...@apache.org> on 2024/05/28 05:44:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16843) Remove preAppendErrors from createPutCacheCallback - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/28 06:02:00 UTC, 0 replies.
- [PR] Fix config name in `ProducerFailureHandlingTest` [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2024/05/28 06:04:58 UTC, 2 replies.
- [jira] [Created] (KAFKA-16847) Revise the README for recent CI changes - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/28 06:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16847) Revise the README for recent CI changes - posted by "Cheng-Kai, Zhang (Jira)" <ji...@apache.org> on 2024/05/28 06:10:00 UTC, 6 replies.
- [jira] [Comment Edited] (KAFKA-15630) Improve documentation of offset.lag.max - posted by "Ganesh Sadanala (Jira)" <ji...@apache.org> on 2024/05/28 06:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15630) Improve documentation of offset.lag.max - posted by "Ganesh Sadanala (Jira)" <ji...@apache.org> on 2024/05/28 06:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15198) Improve version release scripts - posted by "Ganesh Sadanala (Jira)" <ji...@apache.org> on 2024/05/28 06:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4094) Fix importance labels for Kafka Server config - posted by "Ganesh Sadanala (Jira)" <ji...@apache.org> on 2024/05/28 06:22:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16847) Revise the README for recent CI changes - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/28 06:24:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16811) Punctuate Ratio metric almost impossible to track - posted by "Ganesh Sadanala (Jira)" <ji...@apache.org> on 2024/05/28 06:26:00 UTC, 0 replies.
- [PR] Fix the config name in `ProducerFailureHandlingTest` [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2024/05/28 06:26:25 UTC, 2 replies.
- [jira] [Created] (KAFKA-16848) Reverting KRaft migration for "Migrating brokers to KRaft" state is wrong - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/28 06:48:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16814) KRaft broker cannot startup when `partition.metadata` is missing - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2024/05/28 07:26:00 UTC, 0 replies.
- [PR] MINOR: Modify doc of advertised.listeners to show supported on KRaft mode. [kafka] - posted by "sasakitoa (via GitHub)" <gi...@apache.org> on 2024/05/28 08:00:36 UTC, 3 replies.
- [jira] [Created] (KAFKA-16849) ERROR Failed to read /opt/kafka/data/meta.properties - posted by "Agostino Sarubbo (Jira)" <ji...@apache.org> on 2024/05/28 08:03:00 UTC, 0 replies.
- [PR] KAFKA-16844: Add ByteBuffer support for Connect ByteArrayConverter [kafka] - posted by "fanyang (via GitHub)" <gi...@apache.org> on 2024/05/28 08:03:55 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16849) ERROR Failed to read /opt/kafka/data/meta.properties - posted by "Agostino Sarubbo (Jira)" <ji...@apache.org> on 2024/05/28 08:05:00 UTC, 1 replies.
- Re: [PR] KAFKA-16617: Include kraft handler in advertised listener doc [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/05/28 08:32:54 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16805) Stop using a ClosureBackedAction to configure Spotbugs reports - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/28 08:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16850) KRaft - Add v2 of TopicRecord - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/28 09:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16851) Add remote.log.disable.policy - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/28 09:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16852) Add *.thread.pool.size - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/28 09:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16515) Fix the ZK Metadata cache use of voter static configuration - posted by "Josep Prat (Jira)" <ji...@apache.org> on 2024/05/28 09:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16516) Fix the controller node provider for broker to control channel - posted by "Josep Prat (Jira)" <ji...@apache.org> on 2024/05/28 09:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16853) Split RemoteLogManagerScheduledThreadPool - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/28 09:30:00 UTC, 0 replies.
- [PR] KeyValue test cases for ToString() method [kafka] - posted by "jayim243 (via GitHub)" <gi...@apache.org> on 2024/05/28 09:34:44 UTC, 0 replies.
- [jira] [Created] (KAFKA-16854) Zookeeper - Add v5 of StopReplica - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/28 09:49:00 UTC, 0 replies.
- [PR] Minor fix invalid name REPLICA_LAG_TIME_MAX_MS_CONFIG [kafka] - posted by "k-raina (via GitHub)" <gi...@apache.org> on 2024/05/28 09:53:28 UTC, 2 replies.
- [jira] [Created] (KAFKA-16855) KRaft - Wire replaying a TopicRecord - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/28 09:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16856) Zookeeper - Add new exception - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/28 09:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16857) Zookeeper - Add new ZNodes - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/28 09:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16857) Zookeeper - Add new ZNodes - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/28 09:59:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14995) Automate asf.yaml collaborators refresh - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/28 10:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16806) Explicitly declare JUnit dependencies for all test modules - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2024/05/28 11:44:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16806) Explicitly declare JUnit dependencies for all test modules - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/28 11:56:00 UTC, 0 replies.
- [PR] Minor: Make VoterSetHistoryTest.testAddAt make sense [kafka] - posted by "dengziming (via GitHub)" <gi...@apache.org> on 2024/05/28 12:55:26 UTC, 0 replies.
- [PR] KAFKA-16483: Remove preAppendErrors from createPutCacheCallback [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2024/05/28 13:18:09 UTC, 0 replies.
- Re: [PR] KAFKA-15265: Integrate RLMQuotaManager for throttling fetches from remote storage [kafka] - posted by "kamalcph (via GitHub)" <gi...@apache.org> on 2024/05/28 13:31:35 UTC, 4 replies.
- [jira] [Created] (KAFKA-16858) Flatten SMT throws NPE - posted by "Adam Strickland (Jira)" <ji...@apache.org> on 2024/05/28 14:04:00 UTC, 0 replies.
- Re: [PR] MINOR: Change KStreamKstreamOuterJoinTest to use distinct left and right types [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/28 14:15:34 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16639) AsyncKafkaConsumer#close does not send heartbeat to leave group - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/28 14:22:00 UTC, 0 replies.
- [PR] KAFKA-16520 KIP-853 Changes to DescribeQuorum request/response [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/05/28 14:23:39 UTC, 11 replies.
- [jira] [Commented] (KAFKA-16639) AsyncKafkaConsumer#close does not send heartbeat to leave group - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/28 14:25:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-16816) Remove unneeded FencedInstanceId support on commit path for new consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/28 14:28:00 UTC, 0 replies.
- [PR] KAFKA-10199: Enable state updater by default [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/28 14:42:30 UTC, 0 replies.
- [PR] MINOR: Remove KafkaConfig dependency in KafkaRequestHandler [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/28 14:50:10 UTC, 8 replies.
- [jira] [Comment Edited] (KAFKA-16837) Kafka Connect fails on update connector for incorrect previous Config Provider tasks - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/28 15:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16837) Kafka Connect fails on update connector for incorrect previous Config Provider tasks - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/28 15:08:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5451) Kafka Connect should scan classpath asynchronously - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/28 15:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6208) Reduce startup time for Kafka Connect workers - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/28 15:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16759) Invalid client telemetry transition on consumer close - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/28 15:34:00 UTC, 0 replies.
- [PR] KAFKA-15853: Move ZKConfigs related static method out of core and into ZKConfigs [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/05/28 16:49:46 UTC, 6 replies.
- [jira] [Comment Edited] (KAFKA-16639) AsyncKafkaConsumer#close does not send heartbeat to leave group - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/28 16:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16516) Fix the controller node provider for broker to control channel - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/28 17:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16515) Fix the ZK Metadata cache use of voter static configuration - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/05/28 17:24:00 UTC, 0 replies.
- [PR] Added test for ClusterConfig [kafka] - posted by "caysony1 (via GitHub)" <gi...@apache.org> on 2024/05/28 17:50:41 UTC, 2 replies.
- [jira] [Created] (KAFKA-16859) Cleanup check if tiered storage is enabled - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/28 18:16:00 UTC, 0 replies.
- [PR] KAFKA-16840: Add --timeout option for ConfigCommand [kafka] - posted by "vishalpalla (via GitHub)" <gi...@apache.org> on 2024/05/28 18:56:23 UTC, 3 replies.
- [PR] Adds a test case to test that an exception is thrown in invalid ports [kafka] - posted by "ahmedryasser (via GitHub)" <gi...@apache.org> on 2024/05/28 18:57:09 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-16796) Introduce new org.apache.kafka.tools.api.Decoder to replace kafka.serializer.Decoder - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/28 19:14:00 UTC, 0 replies.
- [PR] MINOR: Delete KafkaSecurityConfigs class [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/28 19:49:31 UTC, 4 replies.
- [jira] [Commented] (KAFKA-16834) add the reason for the failure of PartitionRegistration#toRecord - posted by "Linu Shibu (Jira)" <ji...@apache.org> on 2024/05/28 20:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16858) Flatten SMT throws NPE - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/28 20:38:00 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-16858) Flatten SMT throws NPE - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/28 20:39:00 UTC, 0 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 13) AssignmentError calculation added [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/28 21:12:55 UTC, 4 replies.
- [PR] KAFKA-16557 Implemented OffsetFetchRequestState toStringBase and added a test for it in CommitRequestManagerTest [kafka] - posted by "brenden20 (via GitHub)" <gi...@apache.org> on 2024/05/28 21:18:29 UTC, 7 replies.
- [jira] [Assigned] (KAFKA-16837) Kafka Connect fails on update connector for incorrect previous Config Provider tasks - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/28 21:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16838) Kafka Connect loads old tasks from removed connectors - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/28 21:29:00 UTC, 0 replies.
- [PR] KAFKA-15853: Move configDef out of core [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/05/28 22:14:59 UTC, 3 replies.
- [jira] [Commented] (KAFKA-15156) Update cipherInformation correctly in DefaultChannelMetadataRegistry - posted by "Arnav Dadarya (Jira)" <ji...@apache.org> on 2024/05/28 22:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16200) Enforce that RequestManager implementations respect user-provided timeout - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/28 23:26:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0) - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/29 00:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0) - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/29 00:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16777) New consumer should throw NoOffsetForPartitionException on continuous poll zero if no reset strategy - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/29 00:25:00 UTC, 0 replies.
- [PR] HOTFIX: remove unnecessary list creation [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/05/29 00:34:54 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16847) Revise the README for recent CI changes - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/29 03:16:00 UTC, 0 replies.
- Re: [PR] MINOR: detect uninitalized MetadataResponse and retry in KafkaAdminCl… [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/29 03:33:11 UTC, 0 replies.
- Re: [PR] DRAFT: State updater with synchronous remove [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/29 03:33:17 UTC, 0 replies.
- [jira] [Created] (KAFKA-16860) Introduce `group.version` feature flag - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/29 06:32:00 UTC, 0 replies.
- [PR] KAFKA-16583: Handle PartitionChangeRecord without directory IDs [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2024/05/29 06:49:14 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16399) Add JBOD support in tiered storage - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/29 07:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13560) Load indexes and data in async manner in the critical path of replica fetcher threads. - posted by "Satish Duggana (Jira)" <ji...@apache.org> on 2024/05/29 08:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13560) Load indexes and data in async manner in the critical path of replica fetcher threads. - posted by "Satish Duggana (Jira)" <ji...@apache.org> on 2024/05/29 08:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16849) ERROR Failed to read /opt/kafka/data/meta.properties - posted by "Lin Siyuan (Jira)" <ji...@apache.org> on 2024/05/29 09:09:00 UTC, 0 replies.
- [PR] ODP-1508 Kafka - Fixing Log4j vulnerability (CVE-2019-17571) detected after ODP upgraded to 3.2.2.0-2 [kafka] - posted by "senthh (via GitHub)" <gi...@apache.org> on 2024/05/29 09:23:11 UTC, 2 replies.
- Re: [PR] KAFKA-14585: Move StorageTool to tools [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2024/05/29 09:26:16 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-14585) Move StorageTool to tools - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2024/05/29 09:27:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-14585) Move StorageTool to tools - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2024/05/29 09:27:00 UTC, 0 replies.
- [PR] KAFKA-16860; [1/2] Introduce group.version feature flag [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/29 11:39:20 UTC, 45 replies.
- [jira] [Resolved] (KAFKA-16832) LeaveGroup API for upgrading ConsumerGroup - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/29 12:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16569) Target Assignment Format Change - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/29 12:15:00 UTC, 0 replies.
- [PR] MINOR: Prevent consumer protocol to be used in ZK mode [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/29 13:29:09 UTC, 5 replies.
- [PR] KAFKA-16837, KAFKA-16838: Discard task configs for deleted connectors, and compare raw task configs before publishing them [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/05/29 14:11:26 UTC, 7 replies.
- [jira] [Resolved] (KAFKA-16705) the flag "started" of RaftClusterInstance is false even though the cluster is started - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/29 14:39:00 UTC, 0 replies.
- Re: [PR] KAFKA-16237: Add Scala 3 support for Kafka Streams [kafka] - posted by "dychko (via GitHub)" <gi...@apache.org> on 2024/05/29 14:39:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16859) Cleanup check if tiered storage is enabled - posted by "黃竣陽 (Jira)" <ji...@apache.org> on 2024/05/29 14:46:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16859) Cleanup check if tiered storage is enabled - posted by "黃竣陽 (Jira)" <ji...@apache.org> on 2024/05/29 14:47:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16859) Cleanup check if tiered storage is enabled - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/29 14:48:00 UTC, 0 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 14) Callback to TaskAssignor::onAssignmenComputed [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/29 15:04:47 UTC, 5 replies.
- [jira] (KAFKA-16820) Kafka Broker fails to connect to Kraft Controller with no DNS matching - posted by "Arushi Helms (Jira)" <ji...@apache.org> on 2024/05/29 15:13:00 UTC, 0 replies.
- Re: [PR] KAFKA-16518; Adding standalone argument for storage [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2024/05/29 15:18:47 UTC, 5 replies.
- [PR] KAFKA-16558 Implemented HeartbeatRequestState toStringBase() and added a test for it [kafka] - posted by "brenden20 (via GitHub)" <gi...@apache.org> on 2024/05/29 15:25:41 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-16722) Add ConsumerGroupPartitionAssignor interface - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/29 15:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16835) Add Support for consumer to read in commit order. - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/05/29 16:32:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16853) Split RemoteLogManagerScheduledThreadPool - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/29 16:39:00 UTC, 1 replies.
- [PR] KAFKA-16766: offset fetch timeout exception in new consumer consistent with legacy [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/05/29 16:39:34 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16853) Split RemoteLogManagerScheduledThreadPool - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/29 16:40:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16854) Zookeeper - Add v5 of StopReplica - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/29 16:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16861) Don't convert to group to classic if the size is larger than group max size - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/29 16:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16771) First log directory printed twice when formatting storage - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/29 17:09:00 UTC, 0 replies.
- [PR] [WIP] KAFKA-16223: Migrate KafkaConfigBackingStoreTest to Mockito [kafka] - posted by "johnnychhsu (via GitHub)" <gi...@apache.org> on 2024/05/29 17:24:46 UTC, 0 replies.
- [jira] [Created] (KAFKA-16862) Refactor ConsumerTaskTest to be deterministic and avoid tight loops - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/29 18:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16863) Consider removing `default.` prefix for exception handler config - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/29 18:20:00 UTC, 0 replies.
- [PR] [Draft]Topic command integration test migrate to new test infra [kafka] - posted by "TaiJuWu (via GitHub)" <gi...@apache.org> on 2024/05/29 18:24:17 UTC, 0 replies.
- [PR] MINOR: make public the consumer group migration policy config [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/05/29 18:54:21 UTC, 2 replies.
- [jira] [Commented] (KAFKA-15305) The background thread should try to process the remaining task until the shutdown timer is expired - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/29 21:28:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-15305) The background thread should try to process the remaining task until the shutdown timer is expired - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/29 21:38:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16864) Copy on write in the Optimized Uniform Assignor - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2024/05/29 21:55:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15305) The background thread should try to process the remaining task until the shutdown timer is expired - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/29 22:00:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0) - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/05/29 22:04:00 UTC, 4 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 15) More TaskAssigmentUtils implementation [WIP] [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/29 23:20:05 UTC, 0 replies.
- [PR] KAFKA-16308 [2/N]: Allow unstable feature versions and rename unstable metadata config [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/05/29 23:41:49 UTC, 7 replies.
- Re: [PR] KAFKA-16790: Update RemoteLogManager configuration in broker server [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/05/30 00:21:33 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16790) Calls to RemoteLogManager are made before it is configured - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/30 00:39:00 UTC, 0 replies.
- Re: [PR] MINOR: Make VoterSetHistoryTest.testAddAt make sense [kafka] - posted by "dengziming (via GitHub)" <gi...@apache.org> on 2024/05/30 02:28:09 UTC, 0 replies.
- Re: [PR] KAFKA-15045: (KIP-924 pt. 15) More TaskAssigmentUtils implementation [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/05/30 02:54:22 UTC, 8 replies.
- Re: [PR] KAFKA-15585: DescribeTopicPartitions client side change [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/30 03:33:08 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16863) Consider removing `default.` prefix for exception handler config - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/05/30 06:08:00 UTC, 1 replies.
- [PR] KAFKA-16854: Add StopReplica v5 [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/05/30 09:05:05 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-16851) Add remote.log.disable.policy - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/30 09:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16862) Refactor ConsumerTaskTest to be deterministic and avoid tight loops - posted by "Anuj Garg (Jira)" <ji...@apache.org> on 2024/05/30 09:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16865) Admin.describeTopics behavior change after KIP-966 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/30 09:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16865) Admin.describeTopics behavior change after KIP-966 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/05/30 09:27:00 UTC, 0 replies.
- [PR] KAFKA-16851: Add remote.log.disable.policy [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/05/30 10:49:52 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16865) Admin.describeTopics behavior change after KIP-966 - posted by "Gantigmaa Selenge (Jira)" <ji...@apache.org> on 2024/05/30 11:42:00 UTC, 0 replies.
- [PR] MINOR: Refactor DynamicConfig [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/30 12:00:07 UTC, 6 replies.
- [PR] KAFKA-16715: Create KafkaShareConsumer interfaces [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2024/05/30 12:01:24 UTC, 1 replies.
- [PR] KAFKA-16802 : Moving java versions inside java block [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2024/05/30 12:36:39 UTC, 2 replies.
- [jira] [Updated] (KAFKA-13295) Long restoration times for new tasks can lead to transaction timeouts - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/05/30 12:38:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-13295) Long restoration times for new tasks can lead to transaction timeouts - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/05/30 12:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13295) Long restoration times for new tasks can lead to transaction timeouts - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/05/30 12:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-13295) Long restoration times for new tasks can lead to transaction timeouts - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/05/30 12:41:00 UTC, 0 replies.
- [PR] Add IncludeTopicAuthorizedOperations option for DescribeTopicPartitionsRequest [kafka] - posted by "tinaselenge (via GitHub)" <gi...@apache.org> on 2024/05/30 12:52:54 UTC, 0 replies.
- [PR] [DO NOT MERGE] PoC for ProcessingExceptionHandler [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/30 13:12:18 UTC, 0 replies.
- Re: [PR] KAFKA-16865: Add IncludeTopicAuthorizedOperations option for DescribeTopicPartitionsRequest [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2024/05/30 13:35:26 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16598) Mirgrate `ResetConsumerGroupOffsetTest` to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/30 13:52:00 UTC, 0 replies.
- [PR] KAFKA-16856 : Adding new exception [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2024/05/30 14:14:31 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16856) Zookeeper - Add new exception - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/30 14:16:00 UTC, 1 replies.
- [PR] MINOR: Enable transaction verification with new group coordinator in TransactionsTest [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/30 14:20:03 UTC, 1 replies.
- [PR] KAFKA-16001 Migrated ConsumerNetworkThreadTest away from ConsumerTestBuilder [kafka] - posted by "brenden20 (via GitHub)" <gi...@apache.org> on 2024/05/30 14:50:51 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-16844) ByteArrayConverter can't convert ByteBuffer - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/30 15:27:00 UTC, 0 replies.
- [PR] Revert "KAFKA-16448: Add ProcessingExceptionHandler in Streams configuration (#16092)" [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/30 15:41:25 UTC, 1 replies.
- [PR] Revert "KAFKA-16448: Add ProcessingExceptionHandler interface and implementations (#16090)" [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/05/30 15:55:24 UTC, 1 replies.
- [PR] KAFKA-14919 sync topic configs test [kafka] - posted by "anton-liauchuk (via GitHub)" <gi...@apache.org> on 2024/05/30 16:10:46 UTC, 2 replies.
- [jira] [Commented] (KAFKA-14919) MM2 ForwardingAdmin tests should not conflate admin operations - posted by "Anton Liauchuk (Jira)" <ji...@apache.org> on 2024/05/30 16:14:00 UTC, 0 replies.
- [PR] Re-add EventAccumulator.poll(long, TimeUnit) [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/05/30 16:17:23 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16664) Re-add EventAccumulator.take(timeout) - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/05/30 16:20:00 UTC, 0 replies.
- Re: [PR] KAFKA-14569: Migrate Connect's integration test EmbeddedKafkaCluster from ZK to KRaft mode [kafka] - posted by "yashmayya (via GitHub)" <gi...@apache.org> on 2024/05/30 16:52:52 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16802) Move build.gradle java version information inside of a java block - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/30 19:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16836) Suspend reason of standby update listener is not correct - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/30 19:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16866) RemoteLogManagerTest.testCopyQuotaManagerConfig failing - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/05/30 20:27:00 UTC, 0 replies.
- [PR] MINOR: Adjust validateOffsetCommit in ConsumerGroup to ensure compatibility with classic protocol members [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/05/30 20:37:02 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-16047) Source connector with EOS enabled have some InitProducerId requests timing out, effectively failing all the tasks & the whole connector - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/30 20:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16833) Cluster missing topicIds from equals and hashCode, PartitionInfo missing equals and hashCode - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/30 21:01:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16833) Cluster missing topicIds from equals and hashCode, PartitionInfo missing equals and hashCode - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/30 21:02:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16866) RemoteLogManagerTest.testCopyQuotaManagerConfig failing - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/30 21:06:00 UTC, 0 replies.
- [PR] KAFKA-16866 RemoteLogManagerTest.testCopyQuotaManagerConfig failing [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/30 21:06:55 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16047) Source connector with EOS enabled have some InitProducerId requests timing out, effectively failing all the tasks & the whole connector - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/30 21:11:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16858) Flatten SMT throws NPE - posted by "Adam Strickland (Jira)" <ji...@apache.org> on 2024/05/30 21:20:00 UTC, 0 replies.
- Re: [PR] KAFKA-15045: (KIP-924 pt. 15) Implement #defaultStandbyTaskAssignment and finish rack-aware standby optimization [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/05/30 22:11:36 UTC, 1 replies.
- [PR] KAFKA-15045: (KIP-924 pt. 16) TaskAssignor.onAssignmentComputed handling [kafka] - posted by "apourchet (via GitHub)" <gi...@apache.org> on 2024/05/30 22:14:50 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16861) Don't convert to group to classic if the size is larger than group max size - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2024/05/31 02:23:00 UTC, 0 replies.
- Re: [PR] ignore [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/05/31 03:33:10 UTC, 0 replies.
- [PR] MINOR: update all-latency-avg documentation [kafka] - posted by "sebastienviale (via GitHub)" <gi...@apache.org> on 2024/05/31 08:21:02 UTC, 7 replies.
- [PR] KAFKA-16860; [2/2] Introduce group.version feature flag [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/31 08:25:51 UTC, 1 replies.
- Re: [PR] KAFKA-16664: Re-add EventAccumulator.poll(long, TimeUnit) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/31 08:33:30 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16824) Utils.getHost and Utils.getPort do not catch a lot of invalid host and ports - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/05/31 08:51:00 UTC, 0 replies.
- [PR] MINOR: Bump trunk to 3.9.0-SNAPSHOT [kafka] - posted by "jlprat (via GitHub)" <gi...@apache.org> on 2024/05/31 09:09:21 UTC, 4 replies.
- [jira] [Updated] (KAFKA-15969) Align RemoteStorageThreadPool metrics name with KIP-405 - posted by "Josep Prat (Jira)" <ji...@apache.org> on 2024/05/31 09:22:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16852) Add *.thread.pool.size - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/31 09:26:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16852) Add *.thread.pool.size - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/31 09:26:00 UTC, 2 replies.
- [PR] KAFKA-16047: Use REQUEST_TIMEOUT_MS_CONFIG in AdminClient.fenceProducers [kafka] - posted by "edoardocomar (via GitHub)" <gi...@apache.org> on 2024/05/31 09:32:16 UTC, 4 replies.
- Re: [PR] KAFKA-16047: Leverage the fenceProducers timeout in the InitProducerId [kafka] - posted by "edoardocomar (via GitHub)" <gi...@apache.org> on 2024/05/31 09:32:57 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16047) Source connector with EOS enabled have some InitProducerId requests timing out, effectively failing all the tasks & the whole connector - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/31 10:03:00 UTC, 0 replies.
- Re: [PR] KAFKA-15265: Dynamic broker configs for remote fetch/copy quotas [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/05/31 10:10:48 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15776) Update delay timeout for DelayedRemoteFetch request - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2024/05/31 10:26:00 UTC, 0 replies.
- [PR] KAFKA-16866: Used the right constant in RLMT#testFetchQuotaManagerConfig [kafka] - posted by "kamalcph (via GitHub)" <gi...@apache.org> on 2024/05/31 10:32:20 UTC, 2 replies.
- [PR] KAFKA-16859: Cleanup check if tiered storage is enabled [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2024/05/31 11:35:08 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16861) Don't convert to group to classic if the size is larger than group max size - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/31 12:18:00 UTC, 0 replies.
- [PR] KAFKA-16852 : Adding two thread pools to Remote Log Manager [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2024/05/31 12:20:03 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16629) add broker-related tests to ConfigCommandIntegrationTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/31 12:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16852) Add *.thread.pool.size - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/31 12:29:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-16766) New consumer offsetsForTimes timeout exception has wrong message - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/05/31 12:56:00 UTC, 0 replies.
- Re: [PR] KAFKA-16463 System test for reverting migration to ZK [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/05/31 13:26:04 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16803) Upgrade to a version of ShadowJavaPlugin which doesn't use ConfigureUtil - posted by "Eric Lu (Jira)" <ji...@apache.org> on 2024/05/31 13:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16775) Fix flaky PlaintextAdminIntegrationTest#testCreateExistingTopicsThrowTopicExistsException - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/31 13:41:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16570) FenceProducers API returns "unexpected error" when successful - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/31 13:44:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16698) Fix flaky kafka.network.DynamicConnectionQuotaTest#testDynamicIpConnectionRateQuota - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2024/05/31 13:46:00 UTC, 3 replies.
- [PR] Minor speed up reset consumer group offset test [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2024/05/31 13:55:40 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16570) FenceProducers API returns "unexpected error" when successful - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/31 14:09:00 UTC, 2 replies.
- [PR] KAFKA-15305: The background thread should try to process the remaining task until the shutdown timer is expired. [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2024/05/31 14:11:29 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16845) Migrate ReplicationQuotasTestRig to new test infra - posted by "黃竣陽 (Jira)" <ji...@apache.org> on 2024/05/31 14:41:00 UTC, 0 replies.
- Re: [PR] KAFKA-16639: Ensure HeartbeatRequestManager generates leave request regardless of in-flight heartbeats. [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2024/05/31 14:47:16 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16838) Kafka Connect loads old tasks from removed connectors - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/05/31 15:02:00 UTC, 0 replies.
- [PR] KAFKA-15718: Refactor UncleanLeaderElectionTest to enable KRaft later [kafka] - posted by "tinaselenge (via GitHub)" <gi...@apache.org> on 2024/05/31 15:28:46 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16845) Migrate ReplicationQuotasTestRig to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/31 16:46:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16811) Punctuate Ratio metric almost impossible to track - posted by "Ganesh Sadanala (Jira)" <ji...@apache.org> on 2024/05/31 16:48:00 UTC, 1 replies.
- Re: [PR] MINOR: speed up reset consumer group offset test [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2024/05/31 17:02:13 UTC, 0 replies.
- [PR] KAFKA-14509: [4/4] Handle includeAuthorizedOperations [kafka] - posted by "riedelmax (via GitHub)" <gi...@apache.org> on 2024/05/31 18:40:47 UTC, 2 replies.
- [PR] SMT InsertField current timestamp [kafka] - posted by "andreit-geomotiv (via GitHub)" <gi...@apache.org> on 2024/05/31 19:45:50 UTC, 0 replies.
- Re: [PR] MINOR: Adjust validateOffsetCommit/Fetch in ConsumerGroup to ensure compatibility with classic protocol members [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/05/31 20:04:19 UTC, 0 replies.
- [PR] KAFKA-16252: Dynamic KRaft network manager and channel [kafka] - posted by "ahuang98 (via GitHub)" <gi...@apache.org> on 2024/05/31 20:10:26 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16639) AsyncKafkaConsumer#close does not send heartbeat to leave group - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/05/31 20:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16860) Introduce `group.version` feature flag - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/31 20:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16864) Copy on write in the Optimized Uniform Assignor - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/05/31 20:21:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16248) Kafka consumer should cache leader offset ranges - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/05/31 21:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16867) Streams should run tag-based standby assignment based on rack ids - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/05/31 21:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16856) Zookeeper - Add new exception - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/05/31 21:32:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16570) FenceProducers API returns "unexpected error" when successful - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2024/05/31 23:00:00 UTC, 0 replies.
- [PR] KAFKA-16858: Throw DataException from validateValue on array and map schemas without inner schemas [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/05/31 23:42:29 UTC, 0 replies.
- [jira] [Created] (KAFKA-16868) Post KIP-924 StreamsPartitionAssignor code cleanup - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/05/31 23:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16869) Rewrite HighAvailabilityTaskAssignor to implement the new TaskAssignor interface - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/05/31 23:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16870) Values.parseString returns objects which fail ConnectSchema.validateValue - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/05/31 23:52:00 UTC, 0 replies.