jira@kafka.apache.org, 2024-02

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

- [jira] [Commented] (KAFKA-12549) Allow state stores to opt-in transactional support - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/01 00:32:00 UTC, 0 replies.
- Re: [PR] KAFKA-16180: Fix UMR and LAIR handling during ZK migration [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/02/01 01:05:37 UTC, 9 replies.
- Re: [PR] KAFKA-16157: fix topic recreation handling with offline disks [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/02/01 03:16:16 UTC, 4 replies.
- [jira] [Created] (KAFKA-16214) No user info when SASL authentication failure - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/01 03:21:00 UTC, 0 replies.
- Re: [PR] KIP-909 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/01 03:33:08 UTC, 0 replies.
- Re: [PR] KAFKA-14585: Refactoring for moving the storage tool [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/02/01 03:54:31 UTC, 0 replies.
- [PR] [WIP] KAFKA-16192: Introduce usage of flexible records to coordinators [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/02/01 04:32:18 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16037) Upgrade existing system tests to use new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:48:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15691) Add new system tests to use new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16152) Fix PlaintextConsumerTest.testStaticConsumerDetectsNewPartitionCreatedAfterRestart - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:48:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15692) New integration tests to ensure full coverage - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:49:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16151) Fix PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:49:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:49:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16135) kafka.api.PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:49:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16150) Fix PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:49:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16134) kafka.api.PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:50:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16009) Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:51:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16104) Enable additional PlaintextConsumerTest tests for new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:51:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15993) Enable max poll integration tests that depend on callback invocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:51:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:51:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16019) Some of the tests in PlaintextConsumer can't seem to deterministically invoke and verify the consumer callback - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:51:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:51:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15848) Consumer API timeout inconsistent between ConsumerDelegate implementations - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:51:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16023) PlaintextConsumerTest needs to wait for reconciliation to complete before proceeding - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:51:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16109) Ensure system tests cover the "simple consumer + commit" use case - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:52:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-16167) Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:54:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-15515) Remove duplicated integration tests for new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:56:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-15986) New consumer group protocol integration test failures - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:56:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15932) Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer") - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:57:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15991) Flaky new consumer test testGroupIdNotNullAndValid - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:57:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15971) Re-enable consumer integration tests for new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:58:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15999) Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15639) Investigate ConsumerNetworkThreadTest's testResetPositionsProcessFailureIsIgnored - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15606) Investigate FetcherTest's/FetchRequestManager's testCompletedFetchRemoval - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15635) Investigate FetcherTest's/FetchRequestManager's testFetcherLeadMetric - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16000) Migrate MembershipManagerImplTest away from ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-14724) Port tests in FetcherTest to FetchRequestManagerTest - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15637) Investigate FetcherTest's/FetchRequestManager's testFetchCompletedBeforeHandlerAdded - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15636) Investigate FetcherTest's/FetchRequestManager's testFetchResponseMetrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16001) Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15652) Add tests to verify OffsetFetcherUtils.getOffsetResetTimestamp() - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15557) Investigate FetcherTest's/FetchRequestManager's duplicate metadata update in assignFromUserNoId - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15634) Investigate FetcherTest's/FetchRequestManager's testQuotaMetrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15638) Investigate ConsumerNetworkThreadTest's testPollResultTimer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15617) Investigate FetcherTest's/FetchRequestManager's testFetchingPendingPartitions and testInflightFetchOnPendingPartitions overlap - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 04:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16115) AsyncKafkaConsumer: Add missing heartbeat metrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 05:04:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16112) Review JMX metrics in Async Consumer and determine the missing ones - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 05:04:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16143) New metrics for KIP-848 protocol - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 05:04:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-16116) AsyncKafkaConsumer: Add missing rebalance metrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 05:04:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16142) Update metrics documentation for errors and new metrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 05:04:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-16113) AsyncKafkaConsumer: Add missing offset commit metrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 05:04:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16156) System test failing for new consumer on endOffsets with negative timestamps - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 06:06:00 UTC, 1 replies.
- Re: [PR] KAFKA-15675: Improve worker liveness check during Connect integration tests [kafka] - posted by "yashmayya (via GitHub)" <gi...@apache.org> on 2024/02/01 07:26:37 UTC, 4 replies.
- Re: [PR] KAFKA-16198: Reconciliation may lose partitions when topic metadata is delayed [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/01 07:55:02 UTC, 0 replies.
- Re: [PR] KAFKA-14589 [1/3] Tests of ConsoleGroupCommand rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/02/01 08:20:31 UTC, 19 replies.
- [jira] [Commented] (KAFKA-15625) Do not flush global state store at each commit - posted by "Ayoub Omari (Jira)" <ji...@apache.org> on 2024/02/01 08:24:00 UTC, 1 replies.
- Re: [PR] KAFKA-16168; Implement GroupCoordinator.onPartitionsDeleted [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/01 08:28:34 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16168) Implement GroupCoordinator.onPartitionsDeleted - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/02/01 08:30:00 UTC, 0 replies.
- Re: [PR] KAFKA-16189; Extend admin to support ConsumerGroupDescribe API [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/01 08:30:58 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16189) Extend admin to support ConsumerGroupDescribe API - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/02/01 08:32:00 UTC, 0 replies.
- Re: [PR] KAFKA-15417 flip joinSpuriousLookBackTimeMs and emit non-joined items [kafka] - posted by "VictorvandenHoven (via GitHub)" <gi...@apache.org> on 2024/02/01 09:05:22 UTC, 17 replies.
- [jira] [Assigned] (KAFKA-15104) Flaky test MetadataQuorumCommandTest for method testDescribeQuorumReplicationSuccessful - posted by "Gantigmaa Selenge (Jira)" <ji...@apache.org> on 2024/02/01 09:34:00 UTC, 0 replies.
- Re: [PR] KAFKA-16154: Broker returns offset for LATEST_TIERED_TIMESTAMP [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/02/01 09:50:00 UTC, 12 replies.
- Re: [PR] KAFKA-14226 (KIP-821): [connect:transform] Introduce support for nested structures [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/01 09:53:40 UTC, 2 replies.
- Re: [PR] KAFKA-16107 [2/N]: Fix inverted args & more tests [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/01 10:27:05 UTC, 2 replies.
- Re: [PR] KAFKA-14412: Add statestore.uncommitted.max.bytes [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/02/01 11:08:48 UTC, 13 replies.
- [jira] [Commented] (KAFKA-16214) No user info when SASL authentication failure - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/01 11:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15912) Parallelize conversion and transformation steps in Connect - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/01 11:43:00 UTC, 0 replies.
- Re: [PR] KAFKA-16214: add client info in authentication error log [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/02/01 12:22:30 UTC, 1 replies.
- Re: [PR] KAFKA-15670: add "inter.broker.listener.name" config in KRaft controller config [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/02/01 12:23:49 UTC, 4 replies.
- Re: [PR] MINOR: log error when initialLoadFuture is not done in authorizer [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/02/01 12:24:15 UTC, 0 replies.
- [PR] KAFKA-16181: Use incrementalAlterConfigs when updating broker configs by kafka-configs.sh [kafka] - posted by "dengziming (via GitHub)" <gi...@apache.org> on 2024/02/01 13:15:43 UTC, 4 replies.
- Re: [PR] KAFKA-15832: Trigger client reconciliation based on manager poll [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/01 13:48:59 UTC, 14 replies.
- [jira] [Created] (KAFKA-16215) Consumer does not rejoin after fenced on delayed revocation - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/01 14:02:00 UTC, 0 replies.
- [PR] KAFKA-16197: Print Connect worker specific logs on poll timeout expiry [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2024/02/01 14:41:08 UTC, 3 replies.
- Re: [PR] KAFKA-15296: Allow offsets to be committed for filtered records when Exactly Once support is disabled [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2024/02/01 14:50:58 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/02/01 14:54:13 UTC, 0 replies.
- Re: [PR] KAFKA-16115: Adding missing heartbeat metrics [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/01 15:15:50 UTC, 12 replies.
- Re: [PR] KAFKA-15062: Adding ppc64le build stage [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/01 15:46:03 UTC, 6 replies.
- Re: [PR] KAFKA-14576: Move ConsoleConsumer to tools [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/01 15:52:53 UTC, 19 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 "C0urante (via GitHub)" <gi...@apache.org> on 2024/02/01 16:29:05 UTC, 2 replies.
- Re: [PR] KAFKA-15575: Begin enforcing 'tasks.max' property for connectors [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/02/01 16:33:07 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15575) Prevent Connectors from exceeding tasks.max configuration - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/02/01 16:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16202) Extra dot in error message in producer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 18:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16215) Consumer does not rejoin after fenced on delayed revocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 18:44:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16215) Consumer does not rejoin after fenced on delayed revocation - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/01 19:13:00 UTC, 2 replies.
- Re: [PR] KAFKA-15307: update/note deprecated configs [kafka] - posted by "Cerchie (via GitHub)" <gi...@apache.org> on 2024/02/01 19:21:40 UTC, 3 replies.
- [jira] [Updated] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 19:56:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16169) FencedException in commitAsync not propagated without callback - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 19:57:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15691) Add new system tests to use new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 19:57: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/02/01 23:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16216) Reduce batch size for initial metadata load during ZK migration - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/02/01 23:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15538) Client support for java regex based subscription - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 23:35:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15561) Client support for new SubscriptionPattern based subscription - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/01 23:35:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16217) Transactional producer stuck in IllegalStateException during close - posted by "Calvin Liu (Jira)" <ji...@apache.org> on 2024/02/01 23:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16217) Transactional producer stuck in IllegalStateException during close - posted by "Calvin Liu (Jira)" <ji...@apache.org> on 2024/02/01 23:40:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-16217) Transactional producer stuck in IllegalStateException during close - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/01 23:46:00 UTC, 1 replies.
- Re: [PR] KAFKA-16216: Reduce batch size for initial metadata load during ZK migration [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/02/01 23:49:20 UTC, 2 replies.
- [PR] MINOR: Add MetadataType metric from KIP-866 #15299 [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/02/01 23:53:24 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16217) Transactional producer stuck in IllegalStateException during close - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 00:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16216) Reduce batch size for initial metadata load during ZK migration - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/02/02 00:16:00 UTC, 0 replies.
- Re: [PR] KAFKA-16101: Additional fixes on KRaft migration documentation [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/02/02 00:22:24 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-16216) Reduce batch size for initial metadata load during ZK migration - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/02/02 00:25:00 UTC, 0 replies.
- Re: [PR] KAFKA-13403 Fix KafkaServer crashes when deleting topics due to the race in log deletion [kafka] - posted by "arunmathew88 (via GitHub)" <gi...@apache.org> on 2024/02/02 01:13:26 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-16217) Transactional producer stuck in IllegalStateException during close - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/02 01:37:00 UTC, 0 replies.
- Re: [PR] KAFKA-15781: KIP-998, Change the ProducerConfig constructor that allows disabling logging to "protected" [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/02 03:33:03 UTC, 0 replies.
- Re: [PR] KAFKA-15335: Support custom SSL configuration for Kafka Connect RestServer [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/02 03:33:18 UTC, 0 replies.
- [jira] [Created] (KAFKA-16218) Partition reassignment can't complete if any target replica is out-of-sync - posted by "Drawxy (Jira)" <ji...@apache.org> on 2024/02/02 07:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16218) Partition reassignment can't complete if any target replica is out-of-sync - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/02 07:10:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16218) Partition reassignment can't complete if any target replica is out-of-sync - posted by "Drawxy (Jira)" <ji...@apache.org> on 2024/02/02 07:16:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5561) Java based TopicCommand to use the Admin client - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/02 09:26:00 UTC, 0 replies.
- Re: [PR] KAFKA-5561: Rewrite TopicCommand using the new Admin client (** WIP do not merge **) [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 09:26:19 UTC, 1 replies.
- Re: [PR] KAFKA-5723[WIP]: Refactor BrokerApiVersionsCommand to use the new AdminClient [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 09:31:15 UTC, 1 replies.
- Re: [PR] KAFKA-15460: Add group type filter to List Groups API [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/02 10:01:55 UTC, 1 replies.
- Re: [PR] WIP - KAFKA-3821 Allowing source tasks to produce offset without emitting r… [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 10:09:07 UTC, 2 replies.
- [jira] [Created] (KAFKA-16219) Tsl13SelectorTest::testExpireClosedConnectionWithPendingReceives hangs infinitely - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/02/02 10:21:00 UTC, 0 replies.
- Re: [PR] MINOR: Add missing @Test annotations to miscellaneous tests [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 10:26:24 UTC, 1 replies.
- Re: [PR] KIP-318: Make Kafka Connect Source idempotent [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 10:28:33 UTC, 1 replies.
- Re: [PR] MINOR: Fixed deprecated Gradle build Properties. [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 10:32:37 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-14454) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions passes when run individually but not when is run as part of the IT - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/02 10:39:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16220) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions flaky - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/02 10:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16220) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions is flaky - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/02 10:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14454) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions passes when run individually but not when is run as part of the IT - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/02 10:42:00 UTC, 0 replies.
- [PR] KAFKA-16220: Increase timeout in KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/02 11:12:55 UTC, 1 replies.
- Re: [PR] MINOR: fix code listings connect.html [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 11:26:04 UTC, 11 replies.
- Re: [PR] MINOR: Fix code listings in quickstart.html [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 11:32:31 UTC, 5 replies.
- Re: [PR] KAFKA-9693: Kafka latency spikes caused by log segment flush on roll [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/02/02 12:07:17 UTC, 3 replies.
- Re: [PR] KAFKA-10047: Unnecessary widening of (int to long) scope in FloatSerializer [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 12:42:29 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-10047) Unnecessary widening of (int to long) scope in FloatSerializer - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/02 12:43:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-10047) Unnecessary widening of (int to long) scope in FloatSerializer - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/02 12:43:00 UTC, 0 replies.
- [PR] Version downgrade for shadow jar plugin [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2024/02/02 12:47:01 UTC, 6 replies.
- Re: [PR] Fix to include runtime dependencies in clients [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2024/02/02 12:47:48 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15697) Add local assignor and ensure it cannot be used with server side assignor - posted by "appchemist (Jira)" <ji...@apache.org> on 2024/02/02 12:49:00 UTC, 1 replies.
- Re: [PR] MINOR: remove un used exception [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 12:49:19 UTC, 1 replies.
- Re: [PR] MINOR: Reuse hasDefault instead of comparing with NO_DEFAULT_VALUE directly [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 12:50:04 UTC, 1 replies.
- Re: [PR] KAFKA-13980: Upgrade from Scala 2.12.15 to 2.12.17 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 12:55:57 UTC, 1 replies.
- Re: [PR] KAFKA-8713 KIP-581: Add new conf serialize.accept.optional.null in connect-json [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 13:08:20 UTC, 1 replies.
- Re: [PR] MINOR: Remove unnecessary log4j-appender dependency and tweak explicit log4j dependency [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 13:12:10 UTC, 0 replies.
- Re: [PR] MINOR: Fix plugin.path link in quickstart [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 13:16:22 UTC, 1 replies.
- Re: [PR] KAFKA-14945: Add Serializer#serializeToByteBuffer() to reduce memory copying [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 13:18:37 UTC, 3 replies.
- Re: [PR] MINOR: Upgrade jqwik to version 1.8.0 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 13:31:20 UTC, 0 replies.
- Re: [PR] MINOR: Upgrade maven Artifact version to 3.9.4 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 13:46:39 UTC, 4 replies.
- Re: [PR] KAFKA-15560: Upgrade argparse4j to 0.9.0 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 13:51:19 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15625) Do not flush global state store at each commit - posted by "Ayoub Omari (Jira)" <ji...@apache.org> on 2024/02/02 13:59:00 UTC, 0 replies.
- Re: [PR] KAFKA-15739: KRaft support in ResetConsumerGroupOffsetTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 13:59:12 UTC, 0 replies.
- Re: [PR] MINOR: Log the ZK dual-write time [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 14:02:49 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9693) Kafka latency spikes caused by log segment flush on roll - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/02 14:06:00 UTC, 0 replies.
- Re: [PR] Suggest for performance fix: KAFKA-9693 Kafka latency spikes caused by log segment flush on roll [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/02/02 14:07:24 UTC, 1 replies.
- Re: [PR] MINOR: Fix toString method of IsolationLevel [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 14:08:34 UTC, 2 replies.
- [jira] [Updated] (KAFKA-9693) Kafka latency spikes caused by log segment flush on roll - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/02 14:11:00 UTC, 0 replies.
- Re: [PR] MINOR: Upgrade jqwik to version 1.8.2 [kafka] - posted by "bmscomp (via GitHub)" <gi...@apache.org> on 2024/02/02 14:18:14 UTC, 1 replies.
- Re: [PR] KAFKA-15728: KRaft support in DescribeUserScramCredentialsRequestNotAuthorizedTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 14:20:19 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15728) KRaft support in DescribeUserScramCredentialsRequestNotAuthorizedTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/02 14:21:00 UTC, 0 replies.
- Re: [PR] MINOR: New year code clean up - misc [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 14:24:48 UTC, 0 replies.
- Re: [PR] KAFKA-15723: KRaft support in ListOffsetsRequestTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 14:26:15 UTC, 0 replies.
- Re: [PR] KAFKA-15882: Add nightly docker image scan job [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 14:29:42 UTC, 2 replies.
- Re: [PR] MINOR: Few cleanups to JaasContext/Utils classes [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 15:01:23 UTC, 1 replies.
- [PR] Upgrade/maven artifact version [kafka] - posted by "bmscomp (via GitHub)" <gi...@apache.org> on 2024/02/02 15:14:39 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16115) AsyncKafkaConsumer: Add missing heartbeat metrics - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/02/02 16:30:00 UTC, 0 replies.
- [PR] Ctr rebalance metrics [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2024/02/02 16:39:59 UTC, 1 replies.
- Re: [PR] KAFKA-15717: Added KRaft support in LeaderEpochIntegrationTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 16:53:21 UTC, 8 replies.
- Re: [PR] KAFKA-15761: KRaft support in EpochDrivenReplicationProtocolAcceptanceTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/02 16:54:28 UTC, 8 replies.
- [PR] KAFKA-16215; KAFKA-16178: Fix member not rejoining after error [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/02/02 17:12:56 UTC, 21 replies.
- [jira] [Commented] (KAFKA-16178) AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/02 17:27:00 UTC, 0 replies.
- Re: [PR] KAFKA-16195: ignore metadata.log.dir failure in ZK mode [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/02/02 17:47:16 UTC, 3 replies.
- Re: [PR] KAFKA-16202: Extra dot in error message in producer [kafka] - posted by "infantlikesprogramming (via GitHub)" <gi...@apache.org> on 2024/02/02 20:11:47 UTC, 9 replies.
- [jira] [Updated] (KAFKA-15942) Implement ConsumerInterceptor - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15270) Integration tests for AsyncConsumer simple consume case - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16111) Implement tests for tricky rebalance callback scenarios - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:15:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16107) Ensure consumer does not start fetching from added partitions until onPartitionsAssigned completes - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16033) Review client retry logic of OffsetFetch and OffsetCommit responses - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16203) AutoCommit of empty offsets blocks following requests due to inflight flag - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16032) Review client errors thrown on OffsetFetch and OffsetCommit failures - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15948) Refactor AsyncKafkaConsumer shutdown - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15832) Trigger client reconciliation based on manager poll - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15846) Review consumer leave group request best effort and response handling - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15325) Integrate topicId in OffsetFetch and OffsetCommit async consumer calls - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15283) Client support for OffsetFetch and OffsetCommit with topic ID - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/02 22:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15970) KIP-951, port newly added tests in FetcherTest.java to FetchRequestManagerTest.ajva - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/03 01:52:00 UTC, 0 replies.
- Re: [PR] KAFKA-15585: DescribeTopicPartitions client side change [kafka] - posted by "artemlivshits (via GitHub)" <gi...@apache.org> on 2024/02/03 03:24:52 UTC, 18 replies.
- [jira] [Resolved] (KAFKA-16157) Topic recreation with offline disk doesn't update leadership/shrink ISR correctly - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/03 07:05:00 UTC, 0 replies.
- [PR] KAFKA-15867: Should ConsumerNetworkThread wrap the exception and notify the polling thread? [kafka] - posted by "Phuc-Hong-Tran (via GitHub)" <gi...@apache.org> on 2024/02/03 13:44:42 UTC, 5 replies.
- Re: [PR] KAFKA-14683 Migrate #testStartPaused to Mockito [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2024/02/03 18:07:34 UTC, 0 replies.
- [jira] [Commented] (KAFKA-12823) Remove Deprecated method KStream#through - posted by "Arnav Dadarya (Jira)" <ji...@apache.org> on 2024/02/03 18:30:00 UTC, 3 replies.
- [PR] KAFKA-14683 Migrate WorkerSinkTaskTest to Mockito (2/4) [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2024/02/03 20:22:55 UTC, 0 replies.
- [PR] Window not honored? Why is X record not dropped? [kafka] - posted by "florin-akermann (via GitHub)" <gi...@apache.org> on 2024/02/03 22:52:33 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window. - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2024/02/03 23:17:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window. - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2024/02/03 23:19:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window. - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2024/02/03 23:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null-key records for left/outer joins unconditionally of the join window. - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2024/02/03 23:21:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null-key records for left/outer joins unconditionally of the join window. - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2024/02/03 23:22:00 UTC, 4 replies.
- Re: [PR] KAFKA-15561: Client support for new SubscriptionPattern based subscription [kafka] - posted by "Phuc-Hong-Tran (via GitHub)" <gi...@apache.org> on 2024/02/04 04:04:38 UTC, 24 replies.
- [jira] [Commented] (KAFKA-15538) Client support for java regex based subscription - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/02/04 08:57:00 UTC, 3 replies.
- Re: [PR] KAFKA-6225: Adds an option to consume continuously [kafka] - posted by "themaxempire23 (via GitHub)" <gi...@apache.org> on 2024/02/04 10:48:51 UTC, 0 replies.
- [jira] [Created] (KAFKA-16221) IllegalStateException from Producer - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/04 22:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16190) Member should send full heartbeat when rejoining - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/05 00:46:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16221) IllegalStateException from Producer - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/05 00:48:00 UTC, 3 replies.
- [PR] KAFKA-16221: hotfix for EOS error handling [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/02/05 00:51:23 UTC, 5 replies.
- [jira] [Commented] (KAFKA-16190) Member should send full heartbeat when rejoining - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/05 00:58:00 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-15722) KRaft support in RackAwareAutoTopicCreationTest - posted by "Quoc Phong Dang (Jira)" <ji...@apache.org> on 2024/02/05 02:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14132) Remaining PowerMock to Mockito tests - posted by "Hector Geraldino (Jira)" <ji...@apache.org> on 2024/02/05 03:02:00 UTC, 2 replies.
- Re: [PR] KAFKA-13965: Add missing doc for socket-server-metrics [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/05 03:33:16 UTC, 0 replies.
- Re: [PR] POC - DO NO MERGE: refactor StreamsConfig [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/05 03:33:19 UTC, 0 replies.
- [PR] KAFKA-14683 Migrate WorkerSinkTaskTest to Mockito (3/3) [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2024/02/05 03:34:30 UTC, 9 replies.
- [jira] [Resolved] (KAFKA-15460) Add group type filter to ListGroups API - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/02/05 08:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13949) Connect /connectors endpoint should support querying the active topics and the task configs - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2024/02/05 10:30:00 UTC, 0 replies.
- [PR] Additional fix on the rollback migration documentation [kafka] - posted by "ppatierno (via GitHub)" <gi...@apache.org> on 2024/02/05 11:02:21 UTC, 7 replies.
- [PR] KAFKA-15722: KRaft support in RackAwareAutoTopicCreationTest [kafka] - posted by "phong260702 (via GitHub)" <gi...@apache.org> on 2024/02/05 11:09:13 UTC, 0 replies.
- [PR] MINOR: Removing `!` and Unused Import [kafka] - posted by "appchemist (via GitHub)" <gi...@apache.org> on 2024/02/05 12:10:31 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/05 13:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/05 13:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8691) Flakey test ProcessorContextTest#shouldNotAllowToScheduleZeroMillisecondPunctuation - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/05 13:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8691) Flakey test ProcessorContextTest#shouldNotAllowToScheduleZeroMillisecondPunctuation - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/05 13:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14385) Flaky Test QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/05 13:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14385) Flaky Test QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/05 13:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14384) Flaky Test SelfJoinUpgradeIntegrationTest.shouldUpgradeWithTopologyOptimizationOff - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/05 13:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14384) Flaky Test SelfJoinUpgradeIntegrationTest.shouldUpgradeWithTopologyOptimizationOff - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/05 13:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16222) Incorrect default user-principal quota after migration - posted by "Dominik (Jira)" <ji...@apache.org> on 2024/02/05 14:43:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-14132) Remaining PowerMock to Mockito tests - posted by "Nelson B. (Jira)" <ji...@apache.org> on 2024/02/05 14:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14132) Remaining PowerMock to Mockito tests - posted by "Nelson B. (Jira)" <ji...@apache.org> on 2024/02/05 14:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16222) Incorrect default user-principal quota after migration - posted by "Dominik (Jira)" <ji...@apache.org> on 2024/02/05 14:57:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16223) Replace EasyMock and PowerMock with Mockito for KafkaConfigBackingStoreTest - posted by "Hector Geraldino (Jira)" <ji...@apache.org> on 2024/02/05 15:13:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16223) Replace EasyMock and PowerMock with Mockito for KafkaConfigBackingStoreTest - posted by "Hector Geraldino (Jira)" <ji...@apache.org> on 2024/02/05 15:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15717) KRaft support in LeaderEpochIntegrationTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/05 15:58:00 UTC, 0 replies.
- Re: [PR] MINOR: Upgrade maven artifact version to 3.9.6 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/05 16:00:52 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16165) Consumer invalid transition on expired poll interval - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/05 16:03:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16224) Fix handling of deleted topic when auto-committing before revocation - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/05 16:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16221) IllegalStateException from Producer - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/05 16:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16221) IllegalStateException from Producer - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/05 16:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16225) Flaky test suite LogDirFailureTest - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/05 18:05:00 UTC, 0 replies.
- Re: [PR] KAFKA-14683 Migrate WorkerSinkTaskTest to Mockito (1/3) [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/02/05 18:53:42 UTC, 2 replies.
- Re: [PR] KAFKA-16087: Remove more leaky NamedTopologyIntegrationTest tests [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/02/05 19:04:45 UTC, 0 replies.
- Re: [PR] KAFKA-14822: Allow restricting File and Directory ConfigProviders to specific paths [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/02/05 19:20:57 UTC, 6 replies.
- [jira] [Updated] (KAFKA-16133) Commits during reconciliation always time out - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/05 19:25:00 UTC, 0 replies.
- Re: [PR] KAFKA-15834: Remove more leaky NamedTopologyIntegrationTest tests [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/02/05 19:39:50 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/05 19:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16110) Implement consumer performance tests - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/05 20:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16110) Implement consumer performance tests - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/05 20:03:00 UTC, 0 replies.
- Re: [PR] Update Streams API broker compat table for AK 3.7 [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/02/05 20:03:18 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16155) Investigate testAutoCommitIntercept - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/05 20:10:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16155) Investigate testAutoCommitIntercept - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/05 20:11:00 UTC, 1 replies.
- [PR] MINOR: extend transaction unit test to validate drain [kafka] - posted by "artemlivshits (via GitHub)" <gi...@apache.org> on 2024/02/05 23:03:41 UTC, 6 replies.
- Re: [PR] KAFKA-13328, KAFKA-13329 (2): Add custom preflight validation support for connector header, key, and value converters [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/02/06 00:46:01 UTC, 0 replies.
- [PR] KAFKA-16102: fix the dynamic modification of listeners' IP or port no… [kafka] - posted by "pjl1070048431 (via GitHub)" <gi...@apache.org> on 2024/02/06 01:45:01 UTC, 0 replies.
- Re: [PR] KAFKA-14683 Migrate WorkerSinkTaskTest to Mockito (2/3) [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2024/02/06 02:33:36 UTC, 5 replies.
- Re: [PR] MINOR: add clarification about log compaction [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/06 03:33:02 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15717) KRaft support in LeaderEpochIntegrationTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/06 10:56:00 UTC, 0 replies.
- [PR] MINOR: Update LICENSE-binary file [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/06 11:32:03 UTC, 2 replies.
- [PR] working change [kafka] - posted by "msn-tldr (via GitHub)" <gi...@apache.org> on 2024/02/06 14:32:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16224) Fix handling of deleted topic when auto-committing before revocation - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/06 14:43:00 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-15970) KIP-951, port newly added tests in FetcherTest.java to FetchRequestManagerTest.ajva - posted by "Mayank Shekhar Narula (Jira)" <ji...@apache.org> on 2024/02/06 14:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16226) Performance regression in Trogdor benchmark with high partition counts - posted by "Mayank Shekhar Narula (Jira)" <ji...@apache.org> on 2024/02/06 15:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16226) Performance regression in Trogdor benchmark with high partition counts - posted by "Mayank Shekhar Narula (Jira)" <ji...@apache.org> on 2024/02/06 15:09:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-16226) Java client: Performance regression in Trogdor benchmark with high partition counts - posted by "Mayank Shekhar Narula (Jira)" <ji...@apache.org> on 2024/02/06 15:15:00 UTC, 20 replies.
- Re: [PR] KAFKA-16066: Upgrade apacheds to 2.0.0.AM27 With apache kerby [kafka] - posted by "highluck (via GitHub)" <gi...@apache.org> on 2024/02/06 15:24:54 UTC, 3 replies.
- Re: [PR] MINOR:Type Casting Correction AND Null Pointer Exception (NPE) Defense [kafka] - posted by "highluck (via GitHub)" <gi...@apache.org> on 2024/02/06 15:40:41 UTC, 2 replies.
- [jira] [Created] (KAFKA-16227) Console consumer fails with `IllegalStateException` - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/02/06 15:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16227) Console consumer fails with `IllegalStateException` - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/02/06 15:58:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-16227) Console consumer fails with `IllegalStateException` - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/06 16:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16228) Add --remote-log-metadata-decoder to kafka-dump-log.sh - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2024/02/06 16:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16228) Add --remote-log-metadata-decoder to kafka-dump-log.sh - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2024/02/06 16:57:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16229) Slow expiration of Producer IDs leading to high CPU usage - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/02/06 17:24:00 UTC, 0 replies.
- [PR] KAFKA-16229: Fix slow expired producer id deletion [kafka] - posted by "jeqo (via GitHub)" <gi...@apache.org> on 2024/02/06 17:28:41 UTC, 16 replies.
- [jira] [Updated] (KAFKA-16229) Slow expiration of Producer IDs leading to high CPU usage - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/02/06 17:45:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16133) Commits during reconciliation always time out - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/06 17:45:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic - posted by "Walker Carlson (Jira)" <ji...@apache.org> on 2024/02/06 18:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16227) Console consumer fails with `IllegalStateException` - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/06 18:57:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16037) Upgrade existing system tests to use new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/06 19:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16037) Update VerifiableConsumer to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/06 19:27:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16230) Update verifiable_consumer to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/06 19:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16230) Update verifiable_consumer.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/06 19:31:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16230) Update verifiable_consumer to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/06 19:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16231) Update consumer_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/06 19:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16231) Update consumer_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/06 19:39:00 UTC, 0 replies.
- [PR] KAFKA-16037: Update VerifiableConsumer to support KIP-848’s group protocol config [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/02/06 19:47:15 UTC, 1 replies.
- Re: [PR] KAFKA-16055: Thread unsafe use of HashMap stored in QueryableStoreProvider#storeProviders [kafka] - posted by "wcarlson5 (via GitHub)" <gi...@apache.org> on 2024/02/06 21:50:54 UTC, 2 replies.
- Re: [PR] KAFKA-16206 Fix unnecessary topic config deletion during ZK migration [kafka] - posted by "ahuang98 (via GitHub)" <gi...@apache.org> on 2024/02/06 22:28:13 UTC, 6 replies.
- Re: [PR] KAFKA-16226 Reduce synchronization between producer threads [kafka] - posted by "hachikuji (via GitHub)" <gi...@apache.org> on 2024/02/06 22:35:45 UTC, 33 replies.
- [PR] KAFKA-7663: Custom Processor supplied on addGlobalStore is not used when restoring state from topic [kafka] - posted by "wcarlson5 (via GitHub)" <gi...@apache.org> on 2024/02/06 22:39:10 UTC, 1 replies.
- [PR] MINOR Fix a case where not all ACLs for a given resource are written to ZK [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/02/06 23:14:29 UTC, 1 replies.
- [PR] KAFKA-16230: Update verifiable_consumer.py to support KIP-848’s group protocol config [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/02/07 01:06:03 UTC, 2 replies.
- [PR] KIP848- Add JMH Benchmarks for Client And Server Side Assignors [kafka] - posted by "rreddy-22 (via GitHub)" <gi...@apache.org> on 2024/02/07 01:30:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14567) Kafka Streams crashes after ProducerFencedException - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/07 01:33:00 UTC, 0 replies.
- [PR] KAFKA-16231: Update consumer_test.py to support KIP-848’s group protocol config [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/02/07 02:04:08 UTC, 4 replies.
- Re: [PR] KAFKA-14517: Implement regex subscriptions [kafka] - posted by "JimmyWang6 (via GitHub)" <gi...@apache.org> on 2024/02/07 02:09:22 UTC, 0 replies.
- [PR] MINOR fix word spelling mistakes [kafka] - posted by "eliasyaoyc (via GitHub)" <gi...@apache.org> on 2024/02/07 02:21:02 UTC, 1 replies.
- [jira] [Created] (KAFKA-16232) kafka hangs forever in the starting process if the authorizer future is not returned - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/07 06:56:00 UTC, 0 replies.
- [PR] KAFKA-16218: Make partition reassignment completed as soon as adding replicas are in-sync [kafka] - posted by "drawxy (via GitHub)" <gi...@apache.org> on 2024/02/07 07:31:56 UTC, 0 replies.
- Re: [PR] KAFKA-15462: Add Group Type Filter for List Group to the Admin Client [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/07 08:55:31 UTC, 33 replies.
- [PR] Added ACLs authorizer change during migration [kafka] - posted by "ppatierno (via GitHub)" <gi...@apache.org> on 2024/02/07 09:51:16 UTC, 2 replies.
- [PR] KAFKA-16155: Re-enable testAutoCommitIntercept [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/07 09:59:53 UTC, 6 replies.
- Re: [PR] KAFKA-7632: Support Compression Level [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/07 10:19:51 UTC, 1 replies.
- Re: [PR] KAFKA-8721: Kafka metrics improvements [kafka] - posted by "anilkulkarnisk (via GitHub)" <gi...@apache.org> on 2024/02/07 11:06:51 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13292) InvalidPidMappingException: The producer attempted to use a producer id which is not currently assigned to its transactional id - posted by "ewolfman (Jira)" <ji...@apache.org> on 2024/02/07 12:04:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15824) SubscriptionState's maybeValidatePositionForCurrentLeader should handle partition which isn't subscribed yet - posted by "Mayank Shekhar Narula (Jira)" <ji...@apache.org> on 2024/02/07 13:49:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-16233) Review auto-commit continuously committing when no progress - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/07 14:19:00 UTC, 0 replies.
- Re: [PR] KAFKA-14133: Move consumer mock in TaskManagerTest to Mockito - part 2 [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/02/07 14:25:34 UTC, 7 replies.
- [jira] [Created] (KAFKA-16234) Log directory failure re-creates partitions in another logdir automatically - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/02/07 15:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16234) Log directory failure re-creates partitions in another logdir automatically - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/02/07 15:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16234) Log directory failure re-creates partitions in another logdir automatically - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/02/07 15:04:00 UTC, 2 replies.
- Re: [PR] mention IdentityReplicationPolicy in ops docs [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/07 17:03:40 UTC, 0 replies.
- Re: [PR] streams-scala: remove collections-compat dependency when on Scala 2.13 [kafka] - posted by "mberndt123 (via GitHub)" <gi...@apache.org> on 2024/02/07 17:30:55 UTC, 3 replies.
- [jira] [Commented] (KAFKA-15467) Kafka broker returns offset out of range for topic/partitions on restart from unclean shutdown - posted by "Steve Jacobs (Jira)" <ji...@apache.org> on 2024/02/07 17:46:00 UTC, 1 replies.
- [PR] KAFKA-16234: Add topicId to Partition constructor [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/02/07 17:48:15 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16234) Log directory failure re-creates partitions in another logdir automatically - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/02/07 18:41:00 UTC, 1 replies.
- [PR] [No review] Repro kafka-16217 [kafka] - posted by "CalvinConfluent (via GitHub)" <gi...@apache.org> on 2024/02/07 18:46:56 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14920) Address timeouts and out of order sequences - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/07 18:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16233) Review auto-commit continuously committing when no progress - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/07 18:58:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16235) auto commit still causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION - posted by "Ryan Leslie (Jira)" <ji...@apache.org> on 2024/02/07 19:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16235) auto commit still causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION - posted by "Ryan Leslie (Jira)" <ji...@apache.org> on 2024/02/07 19:07:00 UTC, 1 replies.
- [jira] [Closed] (KAFKA-16121) Partition reassignments in ZK migration dual write mode stalled until leader epoch incremented - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:08:00 UTC, 1 replies.
- [jira] [Closed] (KAFKA-15694) New integration tests to have full coverage for preview - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16121) Partition reassignments in ZK migration dual write mode stalled until leader epoch incremented - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:09:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-15840) Correct initialization of ConsumerGroupHeartbeat by client - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:09:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-15651) Investigate auto commit guarantees during Consumer.assign() - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:11:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-15592) Member does not need to always try to join a group when a groupId is configured - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:12:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-15573) Implement auto-commit on partition assignment revocation - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:12:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-15631) Do not send new heartbeat request while another one in-flight - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:12:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-15543) Send HB request right after reconciliation completes - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:13:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-15515) Remove duplicated integration tests for new consumer - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:14:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-15539) Client should stop fetching while partitions being revoked - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16121) Partition reassignments in ZK migration dual write mode stalled until leader epoch incremented - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15694) New integration tests to have full coverage for preview - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:20:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15840) Correct initialization of ConsumerGroupHeartbeat by client - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:20:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15540) Handle heartbeat and revocation when consumer leaves group - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:21:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15573) Implement auto-commit on partition assignment revocation - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:21:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15592) Member does not need to always try to join a group when a groupId is configured - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:21:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15539) Client should stop fetching while partitions being revoked - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:21:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15543) Send HB request right after reconciliation completes - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:21:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15631) Do not send new heartbeat request while another one in-flight - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:21:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15651) Investigate auto commit guarantees during Consumer.assign() - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/02/07 20:21:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16178) AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/07 20:23:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16156) System test failing for new consumer on endOffsets with negative timestamps - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/07 20:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14747) FK join should record discarded subscription responses - posted by "Ayoub Omari (Jira)" <ji...@apache.org> on 2024/02/07 20:27:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-15615) Improve handling of fetching during metadata updates - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/07 20:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15639) Investigate ConsumerNetworkThreadTest's testResetPositionsProcessFailureIsIgnored - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/07 20:32:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16001) Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/07 20:33:00 UTC, 0 replies.
- [PR] Global state store restore custom processor [kafka] - posted by "wcarlson5 (via GitHub)" <gi...@apache.org> on 2024/02/07 20:50:17 UTC, 0 replies.
- Re: [PR] MINOR: Fix some MetadataDelta handling issues during ZK migration [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/02/07 20:55:02 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16055) Thread unsafe use of HashMap stored in QueryableStoreProvider#storeProviders - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/02/07 21:07:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16055) Thread unsafe use of HashMap stored in QueryableStoreProvider#storeProviders - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/02/07 21:08:00 UTC, 1 replies.
- [PR] Kafka streams scala3 [kafka] - posted by "mberndt123 (via GitHub)" <gi...@apache.org> on 2024/02/08 00:48:08 UTC, 5 replies.
- Re: [PR] MINOR: remove un used code [kafka] - posted by "highluck (via GitHub)" <gi...@apache.org> on 2024/02/08 01:15:38 UTC, 1 replies.
- Re: [PR] MINOR: Fix uses of ConfigException [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/08 03:33:08 UTC, 0 replies.
- Re: [PR] Update subscriptions at the end. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/08 03:33:09 UTC, 1 replies.
- [PR] KAFKA-16116 [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2024/02/08 05:18:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-16236) Interactive Query v2 does not support Global KTables - posted by "Christian Zügner (Jira)" <ji...@apache.org> on 2024/02/08 08:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16236) Interactive Query v2 does not support Global KTables - posted by "Christian Zügner (Jira)" <ji...@apache.org> on 2024/02/08 08:21:00 UTC, 0 replies.
- Re: [PR] KAFKA-3736: Add HTTP Metrics reporter [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 09:21:05 UTC, 1 replies.
- [PR] MINOR: EventAccumulator should signal to one thread when key becomes available [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/08 09:45:18 UTC, 1 replies.
- Re: [PR] KAFKA-3987: Allow config of the hash algorithm used by the log cleaner [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 09:57:03 UTC, 1 replies.
- Re: [PR] MINOR: Remove unused configuration setting [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 09:59:09 UTC, 1 replies.
- Re: [PR] KAFKA-5197: add a tool analyzing zookeeper client performance across its various apis [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 10:00:21 UTC, 1 replies.
- Re: [PR] kafkatest: Make ZooKeeper log in "DEBUG" mode by default [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 10:02:28 UTC, 1 replies.
- Re: [PR] MINOR: Allow KafkaZkClient and ZooKeeperClient to wait for the underlying ZooKeeper client to fully close. [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 10:03:17 UTC, 1 replies.
- Re: [PR] KAFKA-9094: Add server-side replica validation for ZK triggered reassignments [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 10:05:35 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-9094) Validate the replicas for partition reassignments triggered through the /admin/reassign_partitions zNode - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/08 10:06:00 UTC, 0 replies.
- Re: [PR] i think ? is bettern than string in understanding [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 10:14:35 UTC, 1 replies.
- Re: [PR] KAFKA-8259: Build an RPM for easier installation [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 10:17:26 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-8259) Build RPM for Kafka - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/08 10:18:00 UTC, 0 replies.
- Re: [PR] MINOR: Make it possible to produce messages with a null body in kafka console producer [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 10:24:30 UTC, 1 replies.
- Re: [PR] KAFKA-12937; mm2 can start from the ending of a topic [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 10:35:24 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-12937) Mirrormaker2 can only start from the beginning of a topic - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/08 10:36:00 UTC, 0 replies.
- Re: [PR] Delete docs/documentation directory [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 10:38:36 UTC, 1 replies.
- Re: [PR] KAFKA-8713 KIP-581 Add accept.optional.null to solve optional null [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 10:41:23 UTC, 1 replies.
- Re: [PR] MINOR: Few cleanups to JaasContext/Utils classes for fix CVE-2023-25194 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 10:47:22 UTC, 1 replies.
- [PR] KAFKA-14569: Migrate Kafka Streams tests from Zookeeper to KRaft [kafka] - posted by "mdedetrich (via GitHub)" <gi...@apache.org> on 2024/02/08 10:48:56 UTC, 5 replies.
- Re: [PR] KAFKA-15201: Allow git push to fail gracefully [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/08 10:49:01 UTC, 1 replies.
- Re: [PR] MINOR: set test global timeout as 10 mins [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/02/08 12:46:30 UTC, 1 replies.
- [PR] MINOR: Problem failing in Scala version 2.12 [kafka] - posted by "highluck (via GitHub)" <gi...@apache.org> on 2024/02/08 14:44:29 UTC, 1 replies.
- [PR] MINOR fix scala compile issue [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/02/08 15:41:13 UTC, 4 replies.
- [jira] [Created] (KAFKA-16237) Kafka-Streams-Scala for Scala 3 - posted by "Matthias Berndt (Jira)" <ji...@apache.org> on 2024/02/08 16:01:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16236) Interactive Query v2 does not support Global KTables - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/08 16:53:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16236) Interactive Query v2 does not support Global KTables - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/08 16:53:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16237) Kafka-Streams-Scala for Scala 3 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/08 16:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16237) Kafka-Streams-Scala for Scala 3 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/08 16:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16237) Kafka-Streams-Scala for Scala 3 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/08 17:00:00 UTC, 0 replies.
- Re: [PR] KAFKA-16116: Rebalance Metrics for AsyncKafkaConsumer [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2024/02/08 17:36:09 UTC, 3 replies.
- [PR] MINOR: fix scala 2.12 compilation [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/02/08 17:39:26 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16235) auto commit still causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/08 18:01:00 UTC, 0 replies.
- Re: [PR] KAFKA-16234: Log directory failure re-creates partitions in another logdir automatically [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/02/08 18:05:34 UTC, 0 replies.
- Re: [PR] KAFKA-15556: Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2024/02/08 18:10:34 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16156) System test failing for new consumer on endOffsets with negative timestamps - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/02/08 20:17:00 UTC, 1 replies.
- [PR] KafkaDockerWrapper: correct KAFKA_HEAP_OPTS server property [kafka] - posted by "mpareja (via GitHub)" <gi...@apache.org> on 2024/02/08 20:33:05 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15983) Kafka-acls should return authorization already done if repeating work is issued - posted by "Anish Lukkireddy (Jira)" <ji...@apache.org> on 2024/02/08 23:53:00 UTC, 0 replies.
- Re: [PR] MINOR: [WIP] debugging [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/09 03:33:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-16238) ConnectRestApiTest broken after KIP-1004 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/09 09:42:00 UTC, 0 replies.
- [PR] KAFKA-16238: Fix ConnectRestApiTest system test [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/09 09:43:26 UTC, 1 replies.
- [jira] [Created] (KAFKA-16239) Clean up references to non-existent IntegrationTestHelper - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/09 10:53:00 UTC, 0 replies.
- Re: [PR] MINOR: ZKAcl Migration Client Test Problem failing in Scala version 2.12 [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/02/09 11:02:50 UTC, 1 replies.
- Re: [PR] MINOR: Improve Code Style [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/02/09 11:16:22 UTC, 0 replies.
- Re: [PR] KAFKA-7504 Mitigate sendfile(2) blocking in network threads by waming up fetch data [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/02/09 11:43:12 UTC, 6 replies.
- [jira] [Commented] (KAFKA-14616) Topic recreation with offline broker causes permanent URPs - posted by "Omnia Ibrahim (Jira)" <ji...@apache.org> on 2024/02/09 12:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14616) Topic recreation with offline broker causes permanent URPs - posted by "Omnia Ibrahim (Jira)" <ji...@apache.org> on 2024/02/09 12:21:00 UTC, 0 replies.
- Re: [PR] KAFKA-14782: Implementation Details Different from Documentation (del… [kafka] - posted by "whiteyesx (via GitHub)" <gi...@apache.org> on 2024/02/09 12:23:35 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16162) New created topics are unavailable after upgrading to 3.7 - posted by "Omnia Ibrahim (Jira)" <ji...@apache.org> on 2024/02/09 12:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16162) New created topics are unavailable after upgrading to 3.7 - posted by "Omnia Ibrahim (Jira)" <ji...@apache.org> on 2024/02/09 12:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14127) KIP-858: Handle JBOD broker disk failure in KRaft - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/09 12:28:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16238) ConnectRestApiTest broken after KIP-1004 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/09 12:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14349) Support dynamically resizing the KRaft controller's thread pools - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/09 12:42:00 UTC, 1 replies.
- [PR] Fix docker image build [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2024/02/09 12:43:23 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-14349) Support dynamically resizing the KRaft controller's thread pools - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/09 12:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-12670) KRaft support for unclean.leader.election.enable - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/09 12:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13835) Fix two bugs related to dynamic broker configs in KRaft - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/09 12:59:00 UTC, 0 replies.
- Re: [PR] [MINOR] Fix docker image build [kafka] - posted by "stanislavkozlovski (via GitHub)" <gi...@apache.org> on 2024/02/09 13:00:22 UTC, 0 replies.
- [jira] [Created] (KAFKA-16240) Flaky test PlaintextAdminIntegrationTest.testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(String).quorum=kraft - posted by "Gantigmaa Selenge (Jira)" <ji...@apache.org> on 2024/02/09 13:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16240) Flaky test PlaintextAdminIntegrationTest.testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(String).quorum=kraft - posted by "Gantigmaa Selenge (Jira)" <ji...@apache.org> on 2024/02/09 13:12:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16102) about DynamicListenerConfig, the dynamic modification of the listener's port or IP does not take effect. - posted by "Jialun Peng (Jira)" <ji...@apache.org> on 2024/02/09 14:07:00 UTC, 0 replies.
- [PR] MINOR: Refactor GroupMetadataManagerTest [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/09 14:51:29 UTC, 11 replies.
- [jira] [Commented] (KAFKA-16239) Clean up references to non-existent IntegrationTestHelper - posted by "Gaurav Salvi (Jira)" <ji...@apache.org> on 2024/02/09 15:41:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16239) Clean up references to non-existent IntegrationTestHelper - posted by "Gaurav Salvi (Jira)" <ji...@apache.org> on 2024/02/09 15:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16241) Kafka Streams hits IllegalStateException trying to recycle a task - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/09 18:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16241) Kafka Streams hits IllegalStateException trying to recycle a task - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/09 18:34:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-16242) Mark flaky tests as integration tests - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/09 18:55:00 UTC, 0 replies.
- [PR] KAFKA-16242: Mark tests with the most flaky failures as integration tests [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/02/09 20:25:54 UTC, 3 replies.
- Re: [PR] KAFKA-15665: Enforce min ISR when complete partition reassignment. [kafka] - posted by "splett2 (via GitHub)" <gi...@apache.org> on 2024/02/09 21:56:38 UTC, 14 replies.
- [jira] [Commented] (KAFKA-16241) Kafka Streams hits IllegalStateException trying to recycle a task - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/02/09 22:24:00 UTC, 1 replies.
- [PR] fix syntax error [kafka] - posted by "mberndt123 (via GitHub)" <gi...@apache.org> on 2024/02/10 00:49:26 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16225) Flaky test suite LogDirFailureTest - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/10 01:01:00 UTC, 1 replies.
- Re: [PR] KAFKA-16242: Mark slowest and most flaky tests as integration tests [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/02/10 02:04:35 UTC, 23 replies.
- Re: [PR] KAFKA-12216; Improve flaky test reporting [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/10 07:31:45 UTC, 0 replies.
- Re: [PR] KAFKA-16123: Fix KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window. [kafka] - posted by "florin-akermann (via GitHub)" <gi...@apache.org> on 2024/02/10 10:30:31 UTC, 1 replies.
- [jira] [Commented] (KAFKA-14606) Use virtual threads to publish Kafka records - posted by "Anurag Agarwal (Jira)" <ji...@apache.org> on 2024/02/10 11:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16084) Simplify and deduplicate StandaloneHerderTest mocking - posted by "Arnav Dadarya (Jira)" <ji...@apache.org> on 2024/02/10 19:12:00 UTC, 2 replies.
- Re: [PR] KAFKA-14957: Update-Description-String [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/02/10 20:46:53 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-14957) Default value for state.dir is confusing - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/10 20:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null-key records for left/outer joins unconditionally of the join window. - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2024/02/10 22:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16123) KStreamKStreamJoinProcessor does not drop late records. - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2024/02/10 22:42:00 UTC, 2 replies.
- [jira] (KAFKA-16123) KStreamKStreamJoinProcessor does not drop late records. - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2024/02/10 22:47:00 UTC, 1 replies.
- Re: [PR] KAFKA-15707: KRaft support in TopicBasedRemoteLogMetadataManagerHarness [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/11 03:33:05 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14041) Avoid the keyword var for a variable declaration in ConfigTransformer - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/02/11 10:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14041) Avoid the keyword var for a variable declaration in ConfigTransformer - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/02/11 10:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8750) Utils#murmur2() method switch case block don't have break - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/02/11 10:37:00 UTC, 0 replies.
- [PR] KAFKA-14041: Avoid the keyword var for a variable declaration [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2024/02/11 10:56:53 UTC, 1 replies.
- [jira] [Commented] (KAFKA-1837) Metadata record future never returns on get call after producer is stopped and messages can't be sent - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/02/11 17:14:00 UTC, 0 replies.
- Re: [PR] KAFKA-15814 Patched the SASL/GSSAPI server construction [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/12 03:33:06 UTC, 0 replies.
- Re: [PR] KAFKA-14133: Move StreamTaskTest to Mockito [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/12 03:33:08 UTC, 0 replies.
- [PR] KAFKA-16239: Clean up references to non-existent IntegrationTestHelper [kafka] - posted by "ghostspiders (via GitHub)" <gi...@apache.org> on 2024/02/12 05:17:36 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16178) AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/02/12 07:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16220) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions is flaky - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/12 09:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16220) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions is flaky - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/12 09:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16243) Idle kafka-console-consumer with new consumer group protocol preemptively leaves group - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/02/12 10:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14041) Avoid the keyword var for a variable declaration in ConfigTransformer - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/12 11:31:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-14041) Avoid the keyword var for a variable declaration in ConfigTransformer - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/12 11:32:00 UTC, 0 replies.
- Re: [PR] fix syntax error in release.py [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/02/12 11:35:00 UTC, 0 replies.
- Re: [PR] MINOR Removed unused CommittedOffsetsFile class. [kafka] - posted by "satishd (via GitHub)" <gi...@apache.org> on 2024/02/12 12:05:03 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16239) Clean up references to non-existent IntegrationTestHelper - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/12 12:29:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16239) Clean up references to non-existent IntegrationTestHelper - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/12 12:30:00 UTC, 0 replies.
- [PR] MINOR: Fix package name for FetchFromFollowerIntegrationTest [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/02/12 12:43:23 UTC, 2 replies.
- [jira] [Created] (KAFKA-16244) Move code style exceptions from suppressions.xml to the code - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/02/12 13:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16244) Move code style exceptions from suppressions.xml to the code - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2024/02/12 15:01:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16225) Flaky test suite LogDirFailureTest - posted by "Omnia Ibrahim (Jira)" <ji...@apache.org> on 2024/02/12 15:04:00 UTC, 0 replies.
- [PR] KAFKA-16225: Set `metadata.log.dir` to broker in KRAFT mode in integration test [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/02/12 15:08:29 UTC, 18 replies.
- [PR] ignore [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/12 15:51:58 UTC, 0 replies.
- Re: [PR] KAFKA-14483 Move/Rewrite of LocalLog to storage module. [kafka] - posted by "satishd (via GitHub)" <gi...@apache.org> on 2024/02/12 15:58:19 UTC, 0 replies.
- [PR] MINOR: log AssignReplicasToDirsRequest dispatch and handling [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/02/12 16:02:08 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16243) Idle kafka-console-consumer with new consumer group protocol preemptively leaves group - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/12 16:26:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16243) Idle kafka-console-consumer with new consumer group protocol preemptively leaves group - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/12 16:56:00 UTC, 1 replies.
- [PR] KAFKA-16033: Commit retry logic fixes [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/02/12 17:57:51 UTC, 9 replies.
- [PR] KAFKA-16167: re-enable PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/02/12 19:40:37 UTC, 2 replies.
- [jira] [Updated] (KAFKA-14919) MM2 ForwardingAdmin tests should not conflate admin operations - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 21:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15349) ducker-ak should fail fast when gradlew systemTestLibs fails - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 21:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16068) Use TestPlugins in ConnectorValidationIntegrationTest to silence plugin scanning errors - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 21:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-13163) MySQL Sink Connector - JsonConverter - DataException: Unknown schema type: null - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 21:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-13338) kafka upgrade 6.1.1 asking to change log.cleanup.policy from delete to compact - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 21:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13338) kafka upgrade 6.1.1 asking to change log.cleanup.policy from delete to compact - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 21:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16229) Slow expiration of Producer IDs leading to high CPU usage - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/12 21:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3213) [CONNECT] It looks like we are not backing off properly when reconfiguring tasks - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 21:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4961) Mirrormaker crash with org.apache.kafka.common.protocol.types.SchemaException - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 22:01:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6340) Support of transactions in KafkaConnect - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 22:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16245) DescribeConsumerGroupTest failing - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/12 22:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7217) Loading dynamic topic data into kafka connector sink using regex - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 22:06:00 UTC, 0 replies.
- Re: [PR] KAFKA-15421: fix network thread leak in testThreadPoolResize [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/02/12 22:14:02 UTC, 2 replies.
- [jira] [Commented] (KAFKA-9070) Kafka Connect - Get the wrong offset value comes from Kafka Connect after increase the number of offset storage topic partition to 3 - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 22:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9376) Plugin class loader not found using MM2 - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 22:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9376) Plugin class loader not found using MM2 - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/12 22:33:00 UTC, 0 replies.
- [PR] KAFKA-15665: Enforce partition reassignment should complete when all target replicas are in ISR [kafka] - posted by "CalvinConfluent (via GitHub)" <gi...@apache.org> on 2024/02/12 23:34:49 UTC, 10 replies.
- [jira] [Updated] (KAFKA-15665) Enforce ISR to have all target replicas when complete partition reassignment - posted by "Calvin Liu (Jira)" <ji...@apache.org> on 2024/02/12 23:36:00 UTC, 0 replies.
- Re: [PR] MINOR: WakeupTrigger cleanup [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/13 03:33:14 UTC, 1 replies.
- Re: [PR] POC: run group coordinator state machine on request handler pool [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/13 03:33:18 UTC, 0 replies.
- [PR] Akcore 10: Add unit tests for KafkaAdminClient.listShareGroups [kafka] - posted by "chirag-wadhwa5 (via GitHub)" <gi...@apache.org> on 2024/02/13 09:13:07 UTC, 1 replies.
- [PR] KAFKA-15625: Do not flush global state store at each commit [kafka] - posted by "AyoubOm (via GitHub)" <gi...@apache.org> on 2024/02/13 10:20:35 UTC, 14 replies.
- [jira] [Created] (KAFKA-16246) Cleanups in ConsoleConsumer - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/13 12:23:00 UTC, 0 replies.
- [PR] Fix: ignore heartbeat response if leaving [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/13 12:46:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-16247) replica keep out-of-sync after migrating broker to KRaft - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/13 13:01:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-16247) 1 replica keep out-of-sync after migrating broker to KRaft - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/13 13:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16248) Kafka consumer should cache leader offset ranges - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/13 13:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16248) Kafka consumer should cache leader offset ranges - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/13 13:26:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15344) Kafka Streams should include the message leader epoch when committing offsets - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/13 13:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16247) replica keep out-of-sync after migrating broker to KRaft - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/13 14:07:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16246) Cleanups in ConsoleConsumer - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/13 14:12:00 UTC, 0 replies.
- [PR] KAFKA-14589: [2/3] Tests of ConsoleGroupCommand rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/02/13 14:42:47 UTC, 2 replies.
- [jira] [Created] (KAFKA-16249) Improve reconciliation state machine - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/02/13 15:45:00 UTC, 0 replies.
- [PR] KAFKA-16249; Improve reconciliation state machine [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/13 15:45:28 UTC, 18 replies.
- Re: [PR] KAFKA-15763; Group Coordinator should not deliver new assignment before previous one is acknowledged [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/13 15:47:39 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14822) Allow restricting File and Directory ConfigProviders to specific paths - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/13 17:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14822) Allow restricting File and Directory ConfigProviders to specific paths - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/13 17:30:00 UTC, 0 replies.
- [PR] KAFKA-14589: [3/3] Tests of ConsoleGroupCommand rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/02/13 18:03:53 UTC, 2 replies.
- Re: [PR] KAFKA-14589 ConsumerGroupCommand rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/02/13 18:19:41 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14576) Move ConsoleConsumer to tools - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/13 18:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16250) Consumer group coordinator should perform sanity check on the offset commits. - posted by "Calvin Liu (Jira)" <ji...@apache.org> on 2024/02/13 19:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16251) Fenced member should not send heartbeats while waiting for onPartitionsLost to complete - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/13 20:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16251) Fenced member should not send heartbeats while waiting for onPartitionsLost to complete - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/13 20:33:00 UTC, 2 replies.
- [PR] MINOR: update leaderAndEpoch before initializing metadata publishers [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/02/14 00:50:14 UTC, 1 replies.
- [PR] MINOR: Remove Connect suppressions which are unnecessary [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/02/14 00:51:29 UTC, 0 replies.
- Re: [PR] MINOR: Remove unused controlPlaneRequestProcessor in BrokerServer. [kafka] - posted by "appchemist (via GitHub)" <gi...@apache.org> on 2024/02/14 01:32:28 UTC, 0 replies.
- Re: [PR] MINOR: clear inFlightCorrelationId when ConnectionState is changed to READY [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/14 03:33:55 UTC, 0 replies.
- Re: [PR] [Draft] KIP-994 (Part 1) Minor Enhancements to ListTransactionsRequest [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/14 03:33:58 UTC, 4 replies.
- [jira] [Created] (KAFKA-16252) Maligned Metrics formatting - posted by "James (Jira)" <ji...@apache.org> on 2024/02/14 06:39:00 UTC, 0 replies.
- Re: [PR] KAFKA-15050: format the prompts in the quickstart [kafka] - posted by "joobisb (via GitHub)" <gi...@apache.org> on 2024/02/14 06:44:03 UTC, 0 replies.
- Re: [PR] MINOR: Clean up core metrics, migration, network, raft, security, serializer, tools, utils, and zookeeper modules [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/14 08:28:56 UTC, 3 replies.
- [PR] MINOR: Fix group metadata loading log [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/14 09:04:50 UTC, 1 replies.
- Re: [PR] KAFKA-8977: Remove MockStreamsMetrics since it is not a mock [kafka] - posted by "joobisb (via GitHub)" <gi...@apache.org> on 2024/02/14 09:04:59 UTC, 3 replies.
- Re: [PR] KAFKA-15770: IQv2 must return immutable position [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/14 09:23:25 UTC, 4 replies.
- [jira] [Created] (KAFKA-16253) kafka_server_alterPartition_metrics_network_io_total is not supported in kafka 3.5.1 - posted by "Janardhana Gopalachar (Jira)" <ji...@apache.org> on 2024/02/14 09:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16253) kafka_server_alterPartition_metrics_network_io_total is not supported in kafka 3.5.1 - posted by "Janardhana Gopalachar (Jira)" <ji...@apache.org> on 2024/02/14 09:48:00 UTC, 0 replies.
- [PR] WIP [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/02/14 10:32:47 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16061) KRaft JBOD follow-ups and improvements - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/02/14 12:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16247) replica keep out-of-sync after migrating broker to KRaft - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/14 12:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13505) Kafka Connect should respect Avro 1.10.X enum defaults spec - posted by "Tommy Becker (Jira)" <ji...@apache.org> on 2024/02/14 13:42:00 UTC, 1 replies.
- [PR] MINOR: Fix KafkaAdminClientTest.testClientInstanceId [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/14 14:17:05 UTC, 1 replies.
- [PR] MINIOR: Remove accidentally logs [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/02/14 14:36:11 UTC, 2 replies.
- Re: [PR] MINOR: Cleanup log.dirs in ReplicaManagerTest on JVM exit [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2024/02/14 14:53:28 UTC, 1 replies.
- [PR] KAFKA-16243: Make sure that we do not exceed max poll interval inside poll [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/14 14:57:17 UTC, 11 replies.
- [jira] [Commented] (KAFKA-16212) Cache partitions by TopicIdPartition instead of TopicPartition - posted by "Omnia Ibrahim (Jira)" <ji...@apache.org> on 2024/02/14 15:09:00 UTC, 4 replies.
- Re: [PR] KAFKA-15586: Clean shutdown detection - server side [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/02/14 15:47:57 UTC, 2 replies.
- [jira] [Created] (KAFKA-16254) Allow MM2 to fully disable offset sync feature - posted by "Omnia Ibrahim (Jira)" <ji...@apache.org> on 2024/02/14 16:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16255) AsyncKafkaConsumer should not use partition.assignment.strategy - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/14 17:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16255) AsyncKafkaConsumer should not use partition.assignment.strategy - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/14 17:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16256) Update ConsumerConfig to validate use of group.remote.assignor and partition.assignment.strategy based on group.protocol - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/14 17:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16256) Update ConsumerConfig to validate use of group.remote.assignor and partition.assignment.strategy based on group.protocol - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/14 17:31:00 UTC, 0 replies.
- Re: [PR] 16069 - prevent re-transform of source-records after retriable exceptions [kafka] - posted by "wasniksudesh (via GitHub)" <gi...@apache.org> on 2024/02/14 18:25:44 UTC, 0 replies.
- [jira] [Created] (KAFKA-16257) SchemaProjector should be extensible to logical types - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 18:52:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-13505) Kafka Connect should respect Avro 1.10.X enum defaults spec - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:02:00 UTC, 0 replies.
- [PR] Image test improvements [kafka] - posted by "ahuang98 (via GitHub)" <gi...@apache.org> on 2024/02/14 19:06:34 UTC, 0 replies.
- [PR] [DRAFT] [KAFKA-16069] Source Tasks re-transform records after Retriable exceptions [kafka] - posted by "wasniksudesh (via GitHub)" <gi...@apache.org> on 2024/02/14 19:12:46 UTC, 0 replies.
- [jira] [Created] (KAFKA-16258) Stale member should trigger onPartitionsLost when leaving group - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/14 19:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16258) Stale member should trigger onPartitionsLost when leaving group - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/14 19:24:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/14 19:25:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/14 19:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8314) Managing the doc field in case of schema projection - kafka connect - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15914) Flaky test - testAlterSinkConnectorOffsetsOverriddenConsumerGroupId - OffsetsApiIntegrationTest - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15891) Flaky test: testResetSinkConnectorOffsetsOverriddenConsumerGroupId – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15918) Flaky test - OffsetsApiIntegrationTest.testResetSinkConnectorOffsets - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15892) Flaky test: testAlterSinkConnectorOffsets – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13756) Connect validate endpoint should return proper response for invalid connector class - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14823) Clean up ConfigProvider API - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13656) Connect Transforms support for nested structures - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14652) Improve MM2 logging by adding the flow information to the context (KIP-916) - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14773) Make MirrorMaker startup synchronous - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-10266) Fix connector configs in docs to mention the correct default value inherited from worker configs - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-10719) MirrorMaker2 fails to update its runtime configuration - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-10719) MirrorMaker2 fails to update its runtime configuration - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-12309) The revocation algorithm produces uneven distributions - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-10735) Kafka producer producing corrupted avro values when confluent cluster is recreated and producer application is not restarted - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9790) Wrong metric bean name for connect worker metrics - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 19:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16145) Windows Kafka Shutdown - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 20:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16259) Immutable MetadataCache to improve client performance - posted by "Zhifeng Chen (Jira)" <ji...@apache.org> on 2024/02/14 20:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16259) Immutable MetadataCache to improve client performance - posted by "Zhifeng Chen (Jira)" <ji...@apache.org> on 2024/02/14 20:15:00 UTC, 2 replies.
- [PR] KAFKA-16165: Fix invalid transition on poll timer expiration [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/02/14 20:20:38 UTC, 8 replies.
- [jira] [Commented] (KAFKA-15841) Add Support for Topic-Level Partitioning in Kafka Connect - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 20:35:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-15407) Not able to connect to kafka from the Private NLB from outside the VPC account - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 20:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15407) Not able to connect to kafka from the Private NLB from outside the VPC account - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 20:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15333) Flaky build failure throwing Connect Exception: Could not connect to server.... - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/14 20:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16260) Remove window.size.ms from StreamsConfig - posted by "Lucia Cerchie (Jira)" <ji...@apache.org> on 2024/02/14 21:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16260) Remove window.size.ms from StreamsConfig - posted by "Lucia Cerchie (Jira)" <ji...@apache.org> on 2024/02/14 21:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16260) Remove window.size.ms from StreamsConfig - posted by "Lucia Cerchie (Jira)" <ji...@apache.org> on 2024/02/14 21:12:00 UTC, 2 replies.
- [PR] KAFKA-16259 Immutable MetadataCache to improve client performance [kafka] - posted by "ericzhifengchen (via GitHub)" <gi...@apache.org> on 2024/02/14 22:13:41 UTC, 9 replies.
- [jira] [Assigned] (KAFKA-16260) Remove window.size.ms from StreamsConfig - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/15 02:06:00 UTC, 0 replies.
- Re: [PR] PROPOSAL: support async event execution in group coordinator [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/15 03:33:12 UTC, 0 replies.
- Re: [PR] improve TopicCommandIntegrationTest to be less flaky [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/02/15 05:14:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16259) Immutable MetadataCache to improve client performance - posted by "Satish Duggana (Jira)" <ji...@apache.org> on 2024/02/15 06:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16223) Replace EasyMock and PowerMock with Mockito for KafkaConfigBackingStoreTest - posted by "Chaitanya Mukka (Jira)" <ji...@apache.org> on 2024/02/15 07:39:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-15997) Ensure fairness in the uniform assignor - posted by "Emanuele Sabellico (Jira)" <ji...@apache.org> on 2024/02/15 11:20:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15997) Ensure fairness in the uniform assignor - posted by "Emanuele Sabellico (Jira)" <ji...@apache.org> on 2024/02/15 11:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15729) KRaft support in GetOffsetShellTest - posted by "Ahmed Sobeh (Jira)" <ji...@apache.org> on 2024/02/15 12:16:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16260) Deprecate window.size.ms in StreamsConfig - posted by "Lucia Cerchie (Jira)" <ji...@apache.org> on 2024/02/15 14:29:00 UTC, 0 replies.
- [PR] Refactor SSL/SASL admin integration tests to not use a custom authorizer [kafka] - posted by "tinaselenge (via GitHub)" <gi...@apache.org> on 2024/02/15 16:15:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-16261) MembershipManagerImpl.updateSubscription fails if already empty subscription - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/02/15 18:10:00 UTC, 0 replies.
- Re: [PR] KAFKA-14588 [WIP] ConfigCommand rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/02/15 19:15:03 UTC, 0 replies.
- [PR] KAFKA-14226: [connect:transform] Introduce support for nested structures [kafka] - posted by "jeqo (via GitHub)" <gi...@apache.org> on 2024/02/15 19:54:46 UTC, 1 replies.
- [PR] KAFKA-14226: feat(connect:transform): Introduce FieldPath abstraction [kafka] - posted by "jeqo (via GitHub)" <gi...@apache.org> on 2024/02/15 20:31:09 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16259) Immutable MetadataCache to improve client performance - posted by "Zhifeng Chen (Jira)" <ji...@apache.org> on 2024/02/15 22:19:00 UTC, 0 replies.
- Re: [PR] KAFKA-16123: KStreamKStreamJoinProcessor does not drop late records. [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/02/16 00:19:45 UTC, 10 replies.
- Re: [PR] KAFKA-10190: To set replication throttling configs at broker entity-default [kafka] - posted by "jianjianjiao (via GitHub)" <gi...@apache.org> on 2024/02/16 01:29:33 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/16 01:53:00 UTC, 1 replies.
- [PR] MINOR: add note about Kafka Streams feature for 3.7 release [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/02/16 02:12:45 UTC, 1 replies.
- [jira] [Commented] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/16 02:25:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16262) Add IQv2 to Kafka Streams documentation - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/16 02:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/16 02:33:00 UTC, 0 replies.
- Re: [PR] MINOR: Make Checkstyle more strict for Connect, restore global code quality checks to 2018 [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/02/16 03:49:40 UTC, 0 replies.
- Re: [PR] KAFKA-16179; Stop processing requests before stopping publishing [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/02/16 05:59:03 UTC, 0 replies.
- [PR] KAFKA-16223: Migrate KafkaConfigBackingStoreTest to Mockito [kafka] - posted by "mukkachaitanya (via GitHub)" <gi...@apache.org> on 2024/02/16 06:00:42 UTC, 0 replies.
- [jira] [Created] (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/02/16 08:20: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/02/16 08:22:00 UTC, 1 replies.
- [PR] MINOR: Improve ListConsumerGroupTest.testListGroupCommand [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/16 10:51:04 UTC, 11 replies.
- Re: [PR] MINOR: Added ACLs authorizer change during migration [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/02/16 10:57:24 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6579) Consolidate window store and session store unit tests into a single class - posted by "Ahmed Sobeh (Jira)" <ji...@apache.org> on 2024/02/16 12:32:00 UTC, 0 replies.
- [PR] KAFKA-16009: Fix PlaintextConsumerTest. testMaxPollIntervalMsDelayInRevocation [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/16 14:28:49 UTC, 8 replies.
- [jira] [Assigned] (KAFKA-16009) Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/16 14:43:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16265) Add durationFilter to ListTransactionsRequest - posted by "Yang Yu (Jira)" <ji...@apache.org> on 2024/02/16 17:09:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16266) Introduce TransactionLastUpdateTimeMs tagged field to DescribeTransactionsResponse - posted by "Yang Yu (Jira)" <ji...@apache.org> on 2024/02/16 17:09:00 UTC, 0 replies.
- Re: [PR] KAFKA-14588 ZK configuration moved to ZkConfig [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/02/16 17:12:51 UTC, 1 replies.
- [PR] KAFKA-16265: KIP-994 (Part 1) Minor Enhancements to ListTransactionsRequest [kafka] - posted by "yyu1993 (via GitHub)" <gi...@apache.org> on 2024/02/16 18:14:35 UTC, 23 replies.
- [PR] KAFKA-16226 Add test for concurrently updatingMetadata and fetching snapshot/cluster [kafka] - posted by "msn-tldr (via GitHub)" <gi...@apache.org> on 2024/02/16 18:29:13 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-15143) MockFixedKeyProcessorContext is missing from test-utils - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/17 01:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15143) MockFixedKeyProcessorContext is missing from test-utils - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/17 01:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2024/02/17 09:11:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2024/02/17 09:14:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16084) Simplify and deduplicate StandaloneHerderTest mocking - posted by "Ahmed Sobeh (Jira)" <ji...@apache.org> on 2024/02/17 14:09:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16072) Create Junit 5 extension to detect thread leak - posted by "Dmitry Werner (Jira)" <ji...@apache.org> on 2024/02/17 17:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16072) Create Junit 5 extension to detect thread leak - posted by "Dmitry Werner (Jira)" <ji...@apache.org> on 2024/02/17 17:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16267) Update consumer_group_command_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/17 18:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16268) Update fetch_from_follower_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/17 18:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16269) Update reassign_partitions_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/17 18:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16270) Update snapshot_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/17 18:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16231) Update consumer_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/17 18:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16271) Update consumer_rolling_upgrade_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/17 18:51:00 UTC, 0 replies.
- [jira] [Created] (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/02/17 18:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16273) Update consume_bench_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/17 18:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16274) Update replica_scale_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/17 18:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16274) Update replica_scale_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/17 18:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16273) Update consume_bench_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/17 18:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16275) Update kraft_upgrade_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/17 18:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16276) Update transactions_test.py to support KIP-848’s group protocol config - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/17 18:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15713) KRaft support in SaslClientsWithInvalidCredentialsTest - posted by "Pavel Pozdeev (Jira)" <ji...@apache.org> on 2024/02/18 15:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/18 21:44:00 UTC, 0 replies.
- [PR] MINOR: Updating comments to match the code. [kafka] - posted by "appchemist (via GitHub)" <gi...@apache.org> on 2024/02/19 02:02:28 UTC, 0 replies.
- [jira] [Created] (KAFKA-16277) CooperativeStickyAssignor does not spread topics evenly among consumer group - posted by "Cameron Redpath (Jira)" <ji...@apache.org> on 2024/02/19 02:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16277) CooperativeStickyAssignor does not spread topics evenly among consumer group - posted by "Cameron Redpath (Jira)" <ji...@apache.org> on 2024/02/19 02:44:00 UTC, 4 replies.
- Re: [PR] MINOR: Fix MetricsTest.testBrokerTopicMetricsBytesInOut assertion [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/19 03:34:10 UTC, 3 replies.
- Re: [PR] KAFKA-14467:Add a test to validate the replica state after processing the OFFSET_MOVED_TO_TIERED_STORAGE error [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/19 03:34:18 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-14014) Flaky test NamedTopologyIntegrationTest.shouldAllowRemovingAndAddingNamedTopologyToRunningApplicationWithMultipleNodesAndResetsOffsets() - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15798) Flaky Test NamedTopologyIntegrationTest.shouldAddAndRemoveNamedTopologiesBeforeStartingAndRouteQueriesToCorrectTopology() - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14432) RocksDBStore relies on finalizers to not leak memory - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14278) Convert INVALID_PRODUCER_EPOCH into PRODUCER_FENCED TxnOffsetCommit - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14415) ThreadCache is getting slower with every additional state store - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14530) Check state updater more than once in process loops - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14309) Kafka Streams upgrade tests do not cover for FK-joins - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (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/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15941) Flaky test: shouldRestoreNullRecord() – org.apache.kafka.streams.integration.RestoreIntegrationTest - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16220) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions is flaky - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15957) ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy broken - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-12935) Flaky Test RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14343) Write upgrade/downgrade tests for enabling the state updater - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15833) Restrict Consumer API to be used from one thread - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7000) KafkaConsumer.position should wait for assignment metadata - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14624) State restoration is broken with standby tasks and cache-enabled stores in processor API - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15832) Trigger client reconciliation based on manager poll - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16077) Streams fails to close task after restoration when input partitions are updated - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15280) Implement client support for selecting KIP-848 server-side assignor - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15803) Update last seen epoch during commit - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15865) Ensure consumer.poll() execute autocommit callback - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14299) Benchmark and stabilize state updater - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15690) EosIntegrationTest is flaky. - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15977) DelegationTokenEndToEndAuthorizationWithOwnerTest leaks threads - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16198) Reconciliation may lose partitions when topic metadata is delayed - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15326) Decouple Processing Thread from Polling Thread - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-13531) Flaky test NamedTopologyIntegrationTest - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14532) Correctly handle failed fetch when partitions unassigned - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16097) State updater removes task without pending action in EOSv2 - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15913) Migrate AsyncKafkaConsumerTest away from ConsumerTestBuilder - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15319) Upgrade rocksdb to fix CVE-2022-37434 - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15942) Implement ConsumerInterceptor - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 09:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16253) kafka_server_alterPartition_metrics_network_io_total is not supported in kafka 3.5.1 - posted by "Janardhana Gopalachar (Jira)" <ji...@apache.org> on 2024/02/19 09:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16253) kafka_server_alterPartition_metrics_network_io_total is not supported in kafka 3.5.1 - posted by "Janardhana Gopalachar (Jira)" <ji...@apache.org> on 2024/02/19 09:26:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-13565) consumer exponential backoff implementation - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/19 09:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-13567) adminClient exponential backoff implementation - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/19 09:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-13566) producer exponential backoff implementation - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/19 09:48:00 UTC, 0 replies.
- Re: [PR] KAFKA-15140: improve TopicCommandIntegrationTest to be less flaky [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/02/19 11:37:33 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15140) Improve TopicCommandIntegrationTest to be less flaky - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/19 11:39:00 UTC, 0 replies.
- [PR] Kafka 16084 Simplify and deduplicate standalone herder test mocking [kafka] - posted by "ahmedsobeh (via GitHub)" <gi...@apache.org> on 2024/02/19 12:45:28 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16084) Simplify and deduplicate StandaloneHerderTest mocking - posted by "Ahmed Sobeh (Jira)" <ji...@apache.org> on 2024/02/19 12:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16167) Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 14:01:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-16167) Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 14:02:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16167) Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/19 14:02:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16258) Stale member should trigger onPartitionsLost when leaving group - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/19 14:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16261) MembershipManagerImpl.updateSubscription fails if already empty subscription - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/19 14:31:00 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-15349) ducker-ak should fail fast when gradlew systemTestLibs fails - posted by "Ahmed Sobeh (Jira)" <ji...@apache.org> on 2024/02/19 14:32:00 UTC, 0 replies.
- [PR] KAFKA-15349 ducker-ak should fail fast when gradlew systemTestLibs fails [kafka] - posted by "ahmedsobeh (via GitHub)" <gi...@apache.org> on 2024/02/19 14:46:29 UTC, 2 replies.
- [PR] KAFKA-15349 ducker-ak should fail fast when gradlew systemTestLibs fails [kafka] - posted by "ahmedsobeh (via GitHub)" <gi...@apache.org> on 2024/02/19 14:57:15 UTC, 0 replies.
- [PR] KAFKA-16251: Fix for not sending heartbeat while fenced [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/02/19 15:21:52 UTC, 8 replies.
- [jira] [Assigned] (KAFKA-16266) Introduce TransactionLastUpdateTimeMs tagged field to DescribeTransactionsResponse - posted by "Ahmed Sobeh (Jira)" <ji...@apache.org> on 2024/02/19 15:59:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15841) Add Support for Topic-Level Partitioning in Kafka Connect - posted by "Henrique Mota (Jira)" <ji...@apache.org> on 2024/02/19 16:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15841) Add Support for Topic-Level Partitioning in Kafka Connect - posted by "Henrique Mota (Jira)" <ji...@apache.org> on 2024/02/19 16:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16278) Missing license for scala related dependencies - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/19 19:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-12622) Automate LICENSE file validation - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/19 19:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16278) Missing license for scala related dependencies - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/19 19:40:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16278) Missing license for scala related dependencies - posted by "Anton Liauchuk (Jira)" <ji...@apache.org> on 2024/02/19 19:44:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16278) Missing license for scala related dependencies - posted by "Anton Liauchuk (Jira)" <ji...@apache.org> on 2024/02/19 19:49:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16278) Missing license for scala related dependencies - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/02/19 19:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16279) Avoid leaking abstractions of `StateStore` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/19 21:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16280) Expose method to determine Metric Measurability - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/02/19 22:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16277) CooperativeStickyAssignor does not spread topics evenly among consumer group - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/02/19 23:37:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-14597) [Streams] record-e2e-latency-max is not reporting correct metrics - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/02/20 00:17:00 UTC, 0 replies.
- [jira] (KAFKA-16102) about DynamicListenerConfig, the dynamic modification of the listener's port or IP does not take effect. - posted by "Jialun Peng (Jira)" <ji...@apache.org> on 2024/02/20 02:49:00 UTC, 0 replies.
- Re: [PR] KAFKA-15349: ducker-ak should fail fast when gradlew systemTestLibs fails [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/02/20 03:19:55 UTC, 0 replies.
- Re: [PR] KAFKA-15801: WIP Add hostname and port in NetworkClient logging and increase connection issues logging severity. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/20 03:33:11 UTC, 0 replies.
- Re: [PR] IGNORE: flaky testing [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/20 03:33:13 UTC, 1 replies.
- Re: [PR] KAFKA-15776: Use the FETCH request timeout as the delay timeout for DelayedRemoteFetch [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/20 03:33:16 UTC, 0 replies.
- Re: [PR] KAFKA-12886: Enable request forwarding by default [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/20 03:33:23 UTC, 0 replies.
- [jira] [Created] (KAFKA-16281) Probable IllegalState possible with KIP-966 - posted by "Jack Vanlightly (Jira)" <ji...@apache.org> on 2024/02/20 08:33:00 UTC, 0 replies.
- Re: [PR] KAFKA-14588 Move DynamicConfig to server-commons [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/02/20 08:36:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-16282) Allow to get last stable offset (LSO) in kafka-get-offsets.sh - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/20 09:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16282) Allow to get last stable offset (LSO) in kafka-get-offsets.sh - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/20 09:08:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16282) Allow to get last stable offset (LSO) in kafka-get-offsets.sh - posted by "Ahmed Sobeh (Jira)" <ji...@apache.org> on 2024/02/20 09:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16282) Allow to get last stable offset (LSO) in kafka-get-offsets.sh - posted by "Ahmed Sobeh (Jira)" <ji...@apache.org> on 2024/02/20 10:02:00 UTC, 6 replies.
- [jira] [Comment Edited] (KAFKA-16282) Allow to get last stable offset (LSO) in kafka-get-offsets.sh - posted by "Ahmed Sobeh (Jira)" <ji...@apache.org> on 2024/02/20 10:15:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function. - posted by "Ondrej Cervinka (Jira)" <ji...@apache.org> on 2024/02/20 10:48:00 UTC, 1 replies.
- Re: [PR] KAFKA-3663 : Implements KIP-59 for a kafka-brokers.sh command [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 11:17:44 UTC, 1 replies.
- Re: [PR] Update KafkaLog4jAppender.java adding SaslMechanism as an option [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 11:21:54 UTC, 1 replies.
- Re: [PR] KAFKA-2111: Add help arguments and required fields [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 11:23:05 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16281) Possible IllegalState with KIP-996 - posted by "Jack Vanlightly (Jira)" <ji...@apache.org> on 2024/02/20 11:29:00 UTC, 1 replies.
- Re: [PR] KIP-228 Negative record timestamp support [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 11:34:11 UTC, 1 replies.
- Re: [PR] java 8 code level update [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 11:38:22 UTC, 1 replies.
- Re: [PR] KAFKA-9800: [KIP-580] Client Exponential Backoff Implementation [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 11:43:38 UTC, 1 replies.
- Re: [PR] KAFKA-10116: GraalVM native-image prototype [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 11:45:37 UTC, 1 replies.
- Re: [PR] KAFKA-10281: [WIP] Add log compression analysis tool KIP-640 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 11:47:32 UTC, 1 replies.
- Re: [PR] KAFKA-10369 [WIP] KIP-655 implementation [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 11:49:14 UTC, 1 replies.
- Re: [PR] KAFKA-10325: KIP-649 implementation [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 11:50:32 UTC, 2 replies.
- Re: [PR] [KAFKA-10718][Kafka Connect]add config settting, skip record when enc… [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 11:54:12 UTC, 1 replies.
- [jira] [Created] (KAFKA-16283) RoundRobinPartitioner will only send to half of the partitions in a topic - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/20 12:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16283) RoundRobinPartitioner will only send to half of the partitions in a topic - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/20 12:01:00 UTC, 8 replies.
- Re: [PR] KAFKA-12744: Breaking change dependency upgrade: "argparse4j" 0.7.0 -->> 0.9.0 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 12:03:11 UTC, 2 replies.
- Re: [PR] KAFKA-12891: KIP-749 Add --files and --file-separator options to the ConsoleProducer (WIP) [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 12:08:56 UTC, 1 replies.
- Re: [PR] Add kafka topic sync offset lag metrics by JMX [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 12:13:20 UTC, 1 replies.
- Re: [PR] [WIP] KAFKA-13567: adminClient exponential backoff implementation for KIP-580 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 12:15:19 UTC, 1 replies.
- Re: [PR] [WIP] KAFKA-13566: producer exponential backoff implementation for KIP-580 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/02/20 12:15:26 UTC, 1 replies.
- [jira] [Created] (KAFKA-16284) Performance regression in RocksDB - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/20 12:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16283) RoundRobinPartitioner will only send to half of the partitions in a topic - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/02/20 12:36:00 UTC, 7 replies.
- [jira] [Created] (KAFKA-16285) Make group metadata available when a new assignment is set in async Kafka consumer - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/02/20 12:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16285) Make group metadata available when a new assignment is set in async Kafka consumer - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/02/20 12:42:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16284) Performance regression in RocksDB - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/20 13:09:00 UTC, 0 replies.
- [PR] KAFKA-16284: Fix performance regression in RocksDB [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/20 13:13:54 UTC, 2 replies.
- Re: [PR] KAFKA-16194: Do not return records from poll if group metadata unknown [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/20 13:29:08 UTC, 9 replies.
- [PR] MINOR: use 2 logdirs in ZK migration system tests [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/02/20 15:38:54 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16111) Implement tests for tricky rebalance callback scenarios - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 17:34:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16285) Make group metadata available when a new assignment is set in async Kafka consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 17:34:00 UTC, 0 replies.
- [PR] KAFKA-14747: record discarded FK join subscription responses [kafka] - posted by "AyoubOm (via GitHub)" <gi...@apache.org> on 2024/02/20 17:41:47 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-14747) FK join should record discarded subscription responses - posted by "Ayoub Omari (Jira)" <ji...@apache.org> on 2024/02/20 18:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16286) KRaft doesn't always notify listener of latest leader - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/02/20 18:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16286) KRaft doesn't always notify listener of latest leader - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/02/20 18:45:00 UTC, 0 replies.
- [PR] MINOR: remove unnecessary logging [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/02/20 18:53:28 UTC, 6 replies.
- [PR] KAFKA-16286; Notify listener of latest leader and epoch [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2024/02/20 19:38:47 UTC, 4 replies.
- [jira] [Updated] (KAFKA-16111) Implement tests for rebalance callback scenarios - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 19:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16111) Implement example test for tricky rebalance callback scenarios - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 19:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16287) Implement example test for common rebalance callback scenarios - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 19:54:00 UTC, 0 replies.
- [PR] KAFKA-16278 Missing license for scala related dependencies [kafka] - posted by "anton-liauchuk (via GitHub)" <gi...@apache.org> on 2024/02/20 19:57:26 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16287) Implement example test for common rebalance callback scenarios - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 19:58:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16199) Prune the event queue if event timeout expired before starting - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16288) Values.convertToDecimal throws ClassCastExceptions on String inputs - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/20 20:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:16:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16208) Design new Consumer timeout policy - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15848) Design solution for inconsistency between ConsumerDelegate timeout policies - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15974) Enforce that event processing respects user-provided timeout - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:22:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16200) Enforce that RequestManager implementations respect user-provided timeout - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:22:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-15993) Enable max poll integration tests that depend on callback invocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:29:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15993) Enable max poll integration tests that depend on callback invocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:30:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16023) PlaintextConsumerTest needs to wait for reconciliation to complete before proceeding - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16019) Some of the tests in PlaintextConsumer can't seem to deterministically invoke and verify the consumer callback - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16019) Some of the tests in PlaintextConsumer can't seem to deterministically invoke and verify the consumer callback - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16200) Enforce that RequestManager implementations respect user-provided timeout - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:34:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16199) Prune the event queue if event timeout expired before starting - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16284) Performance regression in RocksDB - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/20 20:46:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-16233) Review auto-commit continuously committing when no progress - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 20:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15475) Request might retry forever even if the user API timeout expires - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 21:46:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-16200) Enforce that RequestManager implementations respect user-provided timeout - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 21:46:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 22:01:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16200) Enforce that RequestManager implementations respect user-provided timeout - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 22:13:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16167) Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 22:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 22:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16152) Fix PlaintextConsumerTest.testStaticConsumerDetectsNewPartitionCreatedAfterRestart - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 22:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16281) Possible IllegalState with KIP-996 - posted by "Artem Livshits (Jira)" <ji...@apache.org> on 2024/02/20 22:36:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/02/20 23:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16289) Values.parseString on heterogeneous lists and maps sometimes corrupts data by inferring incorrect schema - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/20 23:23:00 UTC, 0 replies.
- [PR] KAFKA-16288, KAFKA-16289: Fix Values convertToDecimal exception and parseString corruption [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/02/21 00:24:26 UTC, 1 replies.
- Re: [PR] MINOR: Document MetadataResponse invariants for name and ID [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/02/21 00:39:21 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6675) Connect workers should log plugin path and available plugins more clearly - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/21 00:45:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16190) Member should send full heartbeat when rejoining - posted by "Quoc Phong Dang (Jira)" <ji...@apache.org> on 2024/02/21 01:12:00 UTC, 0 replies.
- [PR] KAFKA-16283: notify users about RoundRobinPartitioner bug [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/02/21 03:43:08 UTC, 4 replies.
- [jira] (KAFKA-16190) Member should send full heartbeat when rejoining - posted by "Quoc Phong Dang (Jira)" <ji...@apache.org> on 2024/02/21 05:29:00 UTC, 0 replies.
- [PR] KAFKA-16190: Member should send full heartbeat when rejoining [kafka] - posted by "phong260702 (via GitHub)" <gi...@apache.org> on 2024/02/21 05:35:06 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16211) Inconsistent config values in CreateTopicsResult and DescribeConfigsResult - posted by "Deng Ziming (Jira)" <ji...@apache.org> on 2024/02/21 06:47:00 UTC, 0 replies.
- [PR] Reduce memory allocation in ClientTelemetryReporter.java [kafka] - posted by "testn (via GitHub)" <gi...@apache.org> on 2024/02/21 08:52:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-16290) Investigate propagating subscription state updates via queues - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/21 09:08:00 UTC, 0 replies.
- [PR] MINOR: Change config. compressionType to be an enum type instead [kafka] - posted by "testn (via GitHub)" <gi...@apache.org> on 2024/02/21 09:12:38 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16290) Investigate propagating subscription state updates via queues - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/21 09:14:00 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-16290) Investigate propagating subscription state updates via queues - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/21 09:16:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16291) Mirrormaker2 wrong checkpoints - posted by "Claudio Benfatto (Jira)" <ji...@apache.org> on 2024/02/21 09:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16291) Mirrormaker2 wrong checkpoints - posted by "Claudio Benfatto (Jira)" <ji...@apache.org> on 2024/02/21 09:31:00 UTC, 0 replies.
- [PR] MINOR: Update dependencies [kafka] - posted by "jlprat (via GitHub)" <gi...@apache.org> on 2024/02/21 09:32:45 UTC, 12 replies.
- [PR] HOTFIX: Fix compilation error in TransactionManagerTest [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/02/21 09:51:24 UTC, 5 replies.
- [PR] MINOR: Reconcile upgrade.html with kafka-site/36's version [kafka] - posted by "stanislavkozlovski (via GitHub)" <gi...@apache.org> on 2024/02/21 10:49:14 UTC, 15 replies.
- [PR] MINOR: Add 3.7 upgrade notes [kafka] - posted by "stanislavkozlovski (via GitHub)" <gi...@apache.org> on 2024/02/21 11:02:44 UTC, 6 replies.
- [jira] [Commented] (KAFKA-16292) Revamp upgrade.html page - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/21 11:15:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-16292) Revamp upgrade.html page - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/21 11:15:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16292) Revamp upgrade.html page - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/02/21 11:16:00 UTC, 1 replies.
- Re: [PR] MINOR: Reduce memory allocation in ClientTelemetryReporter.java [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/02/21 12:54:28 UTC, 8 replies.
- [PR] KAFKA-16287: Implement example test for common rebalance callback [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/21 13:33:49 UTC, 0 replies.
- Re: [PR] KAFKA-16287: Implement example tests for common rebalance callback [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/21 13:34:07 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16185) Fix client reconciliation of same assignment received in different epochs - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/21 14:07:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-15839) Topic ID integration in consumer subscription state - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/21 14:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15847) Consider partial metadata requests for client reconciliation - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/21 14:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15843) Review consumer onPartitionsAssigned called with empty partitions - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/21 14:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16004) Review new consumer inflight offset commit logic - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/21 14:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16103) Review client logic for triggering offset commit callbacks - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/21 14:13:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16293) Test log directory failure in Kraft - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/02/21 14:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16293) Test log directory failure in Kraft - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/02/21 14:20:00 UTC, 0 replies.
- Re: [PR] KAFKA-15143: Adding in MockFixedKeyProcessorContext and Test [kafka] - posted by "s7pandey (via GitHub)" <gi...@apache.org> on 2024/02/21 14:21:49 UTC, 1 replies.
- [PR] KAFKA-16293: Test log directory failure in Kraft [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/02/21 14:26:56 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/21 15:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/21 15:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/21 15:15:00 UTC, 0 replies.
- [PR] KAFKA-15610: Fix CoreUtils.swallow() test gaps [kafka] - posted by "ghostspiders (via GitHub)" <gi...@apache.org> on 2024/02/21 15:32:44 UTC, 3 replies.
- [jira] [Updated] (KAFKA-16290) Investigate propagating subscription state updates via queues - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/21 16:14:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-15538) Client support for java regex based subscription - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/02/21 16:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/02/21 17:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15898) Flaky test: testFenceMultipleBrokers() – org.apache.kafka.controller.QuorumControllerTest - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/21 18:24:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15898) Flaky test: testFenceMultipleBrokers() – org.apache.kafka.controller.QuorumControllerTest - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/21 18:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16291) Mirrormaker2 wrong checkpoints - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/21 19:01:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-16291) Mirrormaker2 wrong checkpoints - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/21 19:02:00 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-15665) Enforce ISR to have all target replicas when complete partition reassignment - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/21 19:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16294) Add group protocol migration enabling config - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/02/21 21:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16294) Add group protocol migration enabling config - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/02/21 21:14:00 UTC, 0 replies.
- [PR] KAFKA-16294: Add group protocol migration enabling config [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/02/21 21:14:50 UTC, 1 replies.
- [PR] MINOR: Fix ReadOnlySessionStore java docs [kafka] - posted by "AyoubOm (via GitHub)" <gi...@apache.org> on 2024/02/21 21:38:28 UTC, 1 replies.
- [PR] Fix documentation for RETRIES_DOC on version 3.2 [kafka] - posted by "federico-weisse-sportsbet (via GitHub)" <gi...@apache.org> on 2024/02/21 22:12:03 UTC, 11 replies.
- [PR] KAFKA-7663: initial commit for reprocessing on user added stores [kafka] - posted by "wcarlson5 (via GitHub)" <gi...@apache.org> on 2024/02/21 22:23:02 UTC, 4 replies.
- [jira] [Created] (KAFKA-16295) Align RocksDB and in-memory store inti() sequence - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/21 22:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16295) Align RocksDB and in-memory store init() sequence - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/02/21 22:42:00 UTC, 1 replies.
- Re: [PR] KAFKA-16186: Broker metrics for client telemetry (KIP-714) [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2024/02/21 23:36:02 UTC, 2 replies.
- [PR] KAFKA-16258: callback to release assignment when stale member leaves group [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/02/22 02:51:35 UTC, 18 replies.
- Re: [PR] MINOR: Test flakyness verification [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/22 03:33:13 UTC, 0 replies.
- [PR] KAFKA-16277: AbstractStickyAssignor - Sort owned TopicPartitions by p… [kafka] - posted by "credpath-seek (via GitHub)" <gi...@apache.org> on 2024/02/22 06:03:19 UTC, 4 replies.
- [PR] KAFKA-14588 [WIP] [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/02/22 07:04:40 UTC, 0 replies.
- [PR] MINOR: Add 3.7 JBOD KRaft Early Acces disclaimer [kafka] - posted by "stanislavkozlovski (via GitHub)" <gi...@apache.org> on 2024/02/22 09:51:52 UTC, 3 replies.
- [PR] KAFKA-16152: Fix PlaintextConsumerTest.testStaticConsumerDetectsNewPartitionCreatedAfterRestart [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/22 10:51:09 UTC, 7 replies.
- [jira] [Created] (KAFKA-16296) Broker shrinks ISR when restarting - posted by "Colin Leroy (Jira)" <ji...@apache.org> on 2024/02/22 10:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16296) Broker shrinks ISR when restarting - posted by "Colin Leroy (Jira)" <ji...@apache.org> on 2024/02/22 11:05:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16082) Broker recreates reassigned partition after logdir failure - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/02/22 12:06:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16292) Revamp upgrade.html page - posted by "Ahmed Sobeh (Jira)" <ji...@apache.org> on 2024/02/22 13:21:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-15991) Flaky new consumer test testGroupIdNotNullAndValid - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/02/22 13:24:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16297) Race condition while promoting future replica can lead to partition unavailability. - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/02/22 13:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16297) Race condition while promoting future replica can lead to partition unavailability. - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2024/02/22 13:49:00 UTC, 0 replies.
- [PR] MINOR: Improve test testCommitInRebalanceCallback [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/22 14:17:01 UTC, 1 replies.
- [jira] [Closed] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/02/22 14:27:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16295) Align RocksDB and in-memory store init() sequence - posted by "Ahmed Sobeh (Jira)" <ji...@apache.org> on 2024/02/22 14:47:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-15555) Ensure wakeups are handled correctly in PrototypeAsyncConsumer.poll() - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/02/22 14:51:00 UTC, 0 replies.
- [PR] KAFKA-16295: Align RocksDB and in-memory store init() sequences [kafka] - posted by "ahmedsobeh (via GitHub)" <gi...@apache.org> on 2024/02/22 14:54:44 UTC, 0 replies.
- [jira] (KAFKA-16295) Align RocksDB and in-memory store init() sequence - posted by "Ahmed Sobeh (Jira)" <ji...@apache.org> on 2024/02/22 14:59:00 UTC, 0 replies.
- Re: [PR] KAFKA-15307: Update/errors for deprecated config [kafka] - posted by "Cerchie (via GitHub)" <gi...@apache.org> on 2024/02/22 15:38:36 UTC, 0 replies.
- [jira] [Created] (KAFKA-16298) Ensure user callbacks exceptions are propagated to the user on consumer poll - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/22 18:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16298) Ensure user callbacks exceptions are propagated to the user on consumer poll - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/22 18:59:00 UTC, 3 replies.
- Re: [PR] MINOR: Disable FetchFromFollowerIntegrationTest.testRackAwareRangeAssignor [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2024/02/22 19:06:38 UTC, 0 replies.
- Re: [PR] KAFKA-15215: [KIP-954] support custom DSL store providers [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2024/02/22 19:14:54 UTC, 5 replies.
- [jira] [Created] (KAFKA-16299) Classic group error responses should contain a no generation id and an empty members list - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/02/22 20:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16300) Wrong documentation for producer config retries - posted by "Fede (Jira)" <ji...@apache.org> on 2024/02/22 20:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16300) Wrong documentation for producer config retries - posted by "Fede (Jira)" <ji...@apache.org> on 2024/02/22 20:52:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16299) Classic group error responses should contain a no generation id and an empty members list - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/02/22 20:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16301) Review fenced member unsubscribe/subscribe callbacks interaction - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/02/22 21:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16294) Add group protocol migration enabling config - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/02/22 22:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16302) Builds failing due to streams test execution failures - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/22 22:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16302) Builds failing due to streams test execution failures - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/22 22:30:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16302) Builds failing due to streams test execution failures - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/22 22:34:00 UTC, 0 replies.
- [PR] KAFKA-16302: Remove check for log message that is no longer present [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/02/22 23:03:26 UTC, 0 replies.
- Re: [PR] KAFKA-16302: Remove check for log message that is no longer present (fix builds) [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/02/22 23:10:18 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-16302) Builds failing due to streams test execution failures - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/22 23:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16301) Review fenced member unsubscribe/subscribe callbacks interaction - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/23 00:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15202) MM2 OffsetSyncStore clears too many syncs when sync spacing is variable - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/23 00:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16302) Builds failing due to streams test execution failures - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/23 01:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16303) Add upgrade notes about recent MM2 offset translation changes - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/02/23 01:18:00 UTC, 0 replies.
- [PR] KAFKA-16303: Add upgrade notes to 3.5.0, 3.5.2, and 3.7.0 about MM2 offset translation [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/02/23 01:20:21 UTC, 0 replies.
- [PR] migrate StreamedJoinTest to Mockito [kafka] - posted by "agavra (via GitHub)" <gi...@apache.org> on 2024/02/23 02:08:26 UTC, 2 replies.
- Re: [PR] MINOR: Update of the PAPI testing classes to the latest implementation [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/02/23 02:15:27 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16277) CooperativeStickyAssignor does not spread topics evenly among consumer group - posted by "Cameron Redpath (Jira)" <ji...@apache.org> on 2024/02/23 02:27:00 UTC, 0 replies.
- Re: [PR] WIP: KAFKA-12549 Prototype for transactional state stores [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/02/23 03:08:34 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-12549) Allow state stores to opt-in transactional support - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/23 03:12:00 UTC, 0 replies.
- Re: [PR] KAFKA-15154: proper StampedLock synchronization added [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/23 03:33:12 UTC, 0 replies.
- Re: [PR] KAFKA-15823: disconnect from controller on AuthenticationException [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/23 03:33:15 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4094) Fix importance labels for Kafka Server config - posted by "Vaibhav Kushwaha (Jira)" <ji...@apache.org> on 2024/02/23 06:21:00 UTC, 0 replies.
- [PR] AKCORE-32: Defined signature for acknowledge functionality and added definition of Share Sessions [kafka] - posted by "adixitconfluent (via GitHub)" <gi...@apache.org> on 2024/02/23 08:16:37 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-15713) KRaft support in SaslClientsWithInvalidCredentialsTest - posted by "Pavel Pozdeev (Jira)" <ji...@apache.org> on 2024/02/23 08:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16105) Reassignment of tiered topics is failing due to RemoteStorageException - posted by "Anatolii Popov (Jira)" <ji...@apache.org> on 2024/02/23 09:37:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16301) Review fenced member unsubscribe/subscribe callbacks interaction - posted by "Quoc Phong Dang (Jira)" <ji...@apache.org> on 2024/02/23 09:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16111) Implement tests for tricky rebalance callback scenarios - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/23 09:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts - posted by "Lenin Joseph (Jira)" <ji...@apache.org> on 2024/02/23 10:18:00 UTC, 0 replies.
- Re: [PR] KAFKA-14808: fix leaderless partition issue when controller removes u… [kafka] - posted by "songnon (via GitHub)" <gi...@apache.org> on 2024/02/23 12:50:45 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16169) FencedException in commitAsync not propagated without callback - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/23 13:42:00 UTC, 0 replies.
- [PR] KAFKA-16285: Make group metadata available when a new assignment is set [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/02/23 13:42:40 UTC, 14 replies.
- Re: [PR] KAFKA-14412: Transactional StateStores [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2024/02/23 14:25:19 UTC, 1 replies.
- [jira] [Created] (KAFKA-16304) Disk I/O error does not offline log directory while handling Fetch requests - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/02/23 15:50:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15853) Move KafkaConfig to server module - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2024/02/23 17:07:00 UTC, 0 replies.
- [PR] [WIp] Fixes consume bench test.py maybe [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/02/23 19:20:34 UTC, 0 replies.
- [PR] ConfigRegistry [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/02/24 00:11:17 UTC, 0 replies.
- Re: [PR] Kafka-14508: ConsumerGroupInstallAssignment API Client [WIP] [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/24 03:33:26 UTC, 0 replies.
- Re: [PR] MINOR: Fix unchecked warning in CredentialCache [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/24 03:33:28 UTC, 0 replies.
- Re: [PR] KAFKA-15821: Delete active topics after connector deletion in standal… [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/24 03:33:30 UTC, 0 replies.
- [PR] KAFKA-15715: Add Kraft Support to UpgradeFeaturesTest [kafka] - posted by "Owen-CH-Leung (via GitHub)" <gi...@apache.org> on 2024/02/24 03:50:01 UTC, 1 replies.
- Re: [PR] KAFKA-15716: KRaft support in EpochDrivenReplicationProtocolAcceptanceTest [kafka] - posted by "highluck (via GitHub)" <gi...@apache.org> on 2024/02/24 10:51:48 UTC, 1 replies.
- Re: [PR] KAFKA-15878: KIP-768 - Extend support for opaque (i.e. non-JWT) tokens in SASL/OAUTHBEARER [kafka] - posted by "omkreddy (via GitHub)" <gi...@apache.org> on 2024/02/24 18:19:54 UTC, 0 replies.
- Re: [PR] KAFKA-15894: Fix KafkaApis.updateRecordConversionStats to ensure MessageConversionsTimeMs and TemporaryMemoryBytes are recorded correctly [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/25 03:33:26 UTC, 0 replies.
- Re: [PR] KAFKA-14588 Log cleaner configuration move to CleanerConfig [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/02/26 07:39:09 UTC, 0 replies.
- Re: [PR] KAFKA-14589 [3/3] Tests of ConsoleGroupCommand rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/02/26 07:39:45 UTC, 1 replies.
- Re: [PR] KAFKA-14589 [2/3] Tests of ConsoleGroupCommand rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/02/26 07:39:55 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16105) Reassignment of tiered topics is failing due to RemoteStorageException - posted by "Anatolii Popov (Jira)" <ji...@apache.org> on 2024/02/26 10:11:00 UTC, 0 replies.
- [PR] MINOR: Optimize EventAccumulator [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/26 10:36:08 UTC, 9 replies.
- [jira] [Resolved] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/26 10:41:00 UTC, 0 replies.
- [PR] MINOR: Bump 3.7 branch's version to 3.7.1-SNAPSHOT [kafka] - posted by "stanislavkozlovski (via GitHub)" <gi...@apache.org> on 2024/02/26 11:12:03 UTC, 0 replies.
- [jira] [Created] (KAFKA-16305) # Optimisation in SslTransportLayer:handshakeUnwrap stalls TLS handshake - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/02/26 12:52:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16305) # Optimisation in SslTransportLayer:handshakeUnwrap stalls TLS handshake - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/02/26 12:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16305) Optimisation in SslTransportLayer:handshakeUnwrap stalls TLS handshake - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/02/26 12:53:00 UTC, 0 replies.
- [PR] MINOR: Fix UpdatedImage and HighWatermarkUpdated events' logs [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/02/26 14:07:12 UTC, 8 replies.
- [jira] [Created] (KAFKA-16306) GroupCoordinatorService logger is not configured - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/02/26 15:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16306) GroupCoordinatorService logger is not configured - posted by "Anton Liauchuk (Jira)" <ji...@apache.org> on 2024/02/26 15:42:00 UTC, 2 replies.
- [PR] KAFKA-16306: fix GroupCoordinatorService logger [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/02/26 15:42:44 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16307) fix EventAccumulator thread idle ratio metric - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/02/26 15:55:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16307) investigate EventAccumulator thread idle ratio metric - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/02/26 15:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16307) investigate EventAccumulator thread idle ratio metric - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/02/26 15:55:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16307) fix EventAccumulator thread idle ratio metric - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/02/26 15:58:00 UTC, 0 replies.
- [PR] KAFKA-16305: Avoid optimisation in handshakeUnwrap [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/02/26 17:54:16 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-14919) MM2 ForwardingAdmin tests should not conflate admin operations - posted by "Anton Liauchuk (Jira)" <ji...@apache.org> on 2024/02/26 18:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9062) Handle stalled writes to RocksDB - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/02/26 18:58:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15695) Local log start offset is not updated on the follower after rebuilding remote log auxiliary state - posted by "Henry Cai (Jira)" <ji...@apache.org> on 2024/02/26 20:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16308) Formatting and Updating Kafka Features - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/02/26 21:22:00 UTC, 0 replies.
- [PR] MINOR: remove test constructor for PartitionAssignment [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/02/26 21:25:49 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/02/26 21:32:13 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16277) CooperativeStickyAssignor does not spread topics evenly among consumer group - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/02/26 21:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16277) CooperativeStickyAssignor does not spread topics evenly among consumer group - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/02/26 21:35:00 UTC, 0 replies.
- [PR] MINOR: Add 3.7.0 to system tests [kafka] - posted by "stanislavkozlovski (via GitHub)" <gi...@apache.org> on 2024/02/26 22:45:18 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16102) about DynamicListenerConfig, the dynamic modification of the listener's port or IP does not take effect. - posted by "Jialun Peng (Jira)" <ji...@apache.org> on 2024/02/27 02:40:00 UTC, 0 replies.
- Re: [PR] KAFKA-15215: migrate StreamedJoinTest to Mockito [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/02/27 02:44:02 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-9062) Handle stalled writes to RocksDB - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/02/27 08:44:00 UTC, 0 replies.
- Re: [PR] KAFKA-16067 Refactoring ConsumerGroupListing + add test [kafka] - posted by "rykovsi (via GitHub)" <gi...@apache.org> on 2024/02/27 13:20:18 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16306) GroupCoordinatorService logger is not configured - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/02/27 15:02:00 UTC, 0 replies.
- [PR] KAFKA-16169: FencedException in commitAsync not propagated without callback [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/27 16:08:08 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-15878) KIP-768: Extend support for opaque (i.e. non-JWT) tokens in SASL/OAUTHBEARER - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/27 17:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15878) KIP-768: Extend support for opaque (i.e. non-JWT) tokens in SASL/OAUTHBEARER - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/27 17:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16309) Enabling virtual threads in the Kafka Consumer - posted by "Soby Chacko (Jira)" <ji...@apache.org> on 2024/02/27 19:59:00 UTC, 0 replies.
- [PR] KAFKA-16191: Clean up of consumer client internal events [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/02/27 22:38:16 UTC, 20 replies.
- [jira] [Assigned] (KAFKA-16290) Investigate propagating subscription state updates via queues - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/28 01:22:00 UTC, 1 replies.
- Re: [PR] DRAFT: State updater with synchronous remove [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/02/28 07:42:26 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15490) Invalid path provided to the log failure channel upon I/O error when writing broker metadata checkpoint - posted by "Alexandre Dupriez (Jira)" <ji...@apache.org> on 2024/02/28 10:42:00 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-15490) Invalid path provided to the log failure channel upon I/O error when writing broker metadata checkpoint - posted by "Alexandre Dupriez (Jira)" <ji...@apache.org> on 2024/02/28 10:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16310) ListOffsets doesn't report the offset with maxTimestamp anymore - posted by "Emanuele Sabellico (Jira)" <ji...@apache.org> on 2024/02/28 10:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16310) ListOffsets doesn't report the offset with maxTimestamp anymore - posted by "Emanuele Sabellico (Jira)" <ji...@apache.org> on 2024/02/28 10:57:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-16311) [Debezium Informix Connector Unable to Commit Processed Log Position] - posted by "Maaheen Yasin (Jira)" <ji...@apache.org> on 2024/02/28 10:59:00 UTC, 0 replies.
- [PR] MINOR: Remove the redundant space in the comments [kafka] - posted by "chiacyu (via GitHub)" <gi...@apache.org> on 2024/02/28 14:09:37 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16311) [Debezium Informix Connector Unable to Commit Processed Log Position] - posted by "Hector Geraldino (Jira)" <ji...@apache.org> on 2024/02/28 14:11:00 UTC, 0 replies.
- [PR] KAFKA-16261: updateSubscription fails if already empty subscription [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/28 15:43:44 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-16261) MembershipManagerImpl.updateSubscription fails if already empty subscription - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/02/28 15:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16116) AsyncKafkaConsumer: Add missing rebalance metrics - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/02/28 17:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16312) ConsumerRebalanceListener.onPartitionsAssigned should be called after joining, even if empty - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/28 17:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16312) ConsumerRebalanceListener.onPartitionsAssigned should be called after joining, even if empty - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/28 17:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16312) ConsumerRebalanceListener.onPartitionsAssigned should be called after joining, even if empty - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/28 18:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16185) Fix client reconciliation of same assignment received in different epochs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/28 18:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16312) ConsumerRebalanceListener.onPartitionsAssigned() should be called after joining, even if empty - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/28 18:35:00 UTC, 0 replies.
- [PR] MINOR: detect uninitalized MetadataResponse and retry in KafkaAdminCl… [kafka] - posted by "cwildman (via GitHub)" <gi...@apache.org> on 2024/02/28 20:52:48 UTC, 0 replies.
- [jira] [Created] (KAFKA-16313) Offline group protocol upgrade - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/02/28 22:41:00 UTC, 0 replies.
- [PR] KAFKA-16313: offline group protocol upgrade [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/02/28 22:46:11 UTC, 6 replies.
- [PR] MINOR: Add 3.7 to Kafka Streams system tests [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/02/28 23:27:01 UTC, 1 replies.
- Re: [PR] KAFKA-15348: add support for 'range IQs with versioned state stores (KIP-969) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/02/29 03:33:42 UTC, 0 replies.
- [jira] [Created] (KAFKA-16314) Add the new ABORTABLE_ERROR - posted by "Sanskar Jhajharia (Jira)" <ji...@apache.org> on 2024/02/29 07:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15462) Add group type filter to the admin client - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/02/29 08:40:00 UTC, 0 replies.
- [PR] KAFKA-16209 : fetchSnapshot might return null if topic is created before v2.8 [kafka] - posted by "chiacyu (via GitHub)" <gi...@apache.org> on 2024/02/29 13:26:11 UTC, 1 replies.
- [jira] [Commented] (KAFKA-12261) Splitting partition causes message loss for consumers with auto.offset.reset=latest - posted by "zhangzhisheng (Jira)" <ji...@apache.org> on 2024/02/29 13:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16314) Add the new ABORTABLE_ERROR - posted by "zhangzhisheng (Jira)" <ji...@apache.org> on 2024/02/29 13:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16314) Add the new ABORTABLE_ERROR - posted by "zhangzhisheng (Jira)" <ji...@apache.org> on 2024/02/29 13:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3370) Add options to auto.offset.reset to reset offsets upon initialization only - posted by "zhangzhisheng (Jira)" <ji...@apache.org> on 2024/02/29 15:42:00 UTC, 0 replies.
- [PR] KAFKA-16167: Disable wakeups during autocommit on close [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/02/29 15:46:27 UTC, 7 replies.
- [PR] KAFKA-16148: Implement GroupMetadataManager#onUnloaded [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/02/29 17:34:12 UTC, 1 replies.
- [jira] [Created] (KAFKA-16315) Investigate propagating metadata updates via queues - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/29 17:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16315) Investigate propagating metadata updates via queues - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/29 17:45:00 UTC, 0 replies.
- Re: [PR] KAFKA-14588 [WIP] ConfigCommand moved to tools [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/02/29 20:14:10 UTC, 0 replies.
- [jira] [Created] (KAFKA-16316) Make the restore behavior of GlobalKTables with custom processors configureable - posted by "Walker Carlson (Jira)" <ji...@apache.org> on 2024/02/29 21:32:00 UTC, 0 replies.
- [PR] MINOR: move TimeRatio to clients common [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/02/29 23:54:50 UTC, 0 replies.
- [jira] [Created] (KAFKA-16317) Add event rate in GroupCoordinatorRuntimeMetrics - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/02/29 23:59:00 UTC, 0 replies.