dev  

Messages by Thread

• Request for JIRA self-assignment permissions Akhil Sabu via dev
  • Re: Request for JIRA self-assignment permissions Akhil Sabu via dev
  • Re: Request for JIRA self-assignment permissions Mickael Maison
• [jira] [Resolved] (KAFKA-20566) Share group deletion in performance test sometimes gets stuck Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-20596) Consider exposing broker-reported Streams group heartbeat status via metrics sanghyeok An (Jira)
• [jira] [Created] (KAFKA-20595) Parallelize loadSegmentFiles Chia-Ping Tsai (Jira)
• [DISCUSS] KIP-1344: Add Transaction Coordinator Metrics for Transaction State Log Appends and Marker Completion Sanghyeok An
• [jira] [Created] (KAFKA-20594) Kafka Streams issue Aayush Gupta (Jira)
• [jira] [Resolved] (KAFKA-1669) Default rebalance retries and backoff should be higher Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1623) kafka is sometimes slow to accept connections Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1626) Use Jekyll for website Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1610) Local modifications to collections generated from mapValues will be lost Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1590) Binarize trace level request logging along with debug level text logging Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1566) Kafka environment configuration (kafka-env.sh) Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1591) Clean-up Unnecessary stack trace in error/warn logs Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1543) Changing replication factor Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1452) Killing last replica for partition doesn't change ISR/Leadership if replica is running controller Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1450) check invalid leader in a more robust way Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1351) String.format is very expensive in Scala Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1313) Support adding replicas to existing topic partitions via kafka-topics tool without manually setting broker assignments Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1352) Reduce logging on the server Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1300) Added WaitForReplaction admin tool. Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1299) Standardize configs across tools Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1206) allow Kafka to start from a resource negotiator system Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1122) Kafka can log giant log lines Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1101) Need better java api for embedding kafkaserver in a java container app Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1088) Ability to create a shadow consumer group Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1043) Time-consuming FetchRequest could block other request in the response queue Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1021) Write a tool to check replica lag for individual topic partitions Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-1014) Junits and system tests for inbuilt offset management Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-960) Upgrade Metrics to 3.x Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-859) support basic auth protection of mx4j console Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-841) Merge the partition and replica state machines into a single unified state machine in the controller Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-747) RequestChannel re-design Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-740) Improve crash-safety of log segment swap Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-566) Add last modified time to the TopicMetadataRequest Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-560) Garbage Collect obsolete topics Matthias J. Sax (Jira)
• [PR] [INFRA] Set up default rulesets for default and release branches [kafka-site] via GitHub
• [DISCUSS] KIP-1340 Pass Join Key to `ValueJoinerWithKey` in Streams-GlobalKTable Joins Lucy Liu via dev
  • Re: [DISCUSS] KIP-1340 Pass Join Key to `ValueJoinerWithKey` in Streams-GlobalKTable Joins Lucy Liu via dev
  • Re: [DISCUSS] KIP-1340 Pass Join Key to `ValueJoinerWithKey` in Streams-GlobalKTable Joins Bill Bejeck
  • Re: [DISCUSS] KIP-1340 Pass Join Key to `ValueJoinerWithKey` in Streams-GlobalKTable Joins Lucy Liu via dev
• [jira] [Resolved] (KAFKA-20575) Add onPartitionsLost support for MockConsumer Aditya Kousik (Jira)
• [jira] [Resolved] (KAFKA-20588) Add restore.buffered.records.per.partition to cap Kafka Streams state-restore memory Muralidhar Basani (Jira)
• KAFKA JIRA permissions Aditya Kousik
  • Re: KAFKA JIRA permissions Lianet Magrans
  • Re: KAFKA JIRA permissions Aditya Kousik
• [jira] [Resolved] (KAFKA-20419) Add SASL docker compose examples for single-node and multi-node clusters Viktor Somogyi-Vass (Jira)
• [jira] [Resolved] (KAFKA-20564) Move AuthorizerTest to server module Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20593) Log a diagnostic warning at startup when Kafka Streams detects internal repartition topics Ankur Sinha (Jira)
• [jira] [Reopened] (KAFKA-20592) Fix several typos in Streams and upgrade documentation Sanskar Jhajharia (Jira)
• [jira] [Resolved] (KAFKA-20592) Fix several typos in Streams and upgrade documentation Akhil Sabu (Jira)
  • [jira] [Resolved] (KAFKA-20592) Fix several typos in Streams and upgrade documentation Akhil Sabu (Jira)
  • [jira] [Resolved] (KAFKA-20592) Fix several typos in Streams and upgrade documentation Akhil Sabu (Jira)
  • [jira] [Resolved] (KAFKA-20592) Fix several typos in Streams and upgrade documentation Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20592) Fix several typos in Streams and upgrade documentation Akhil Sabu (Jira)
• [Discussion] Debo Data Studio: Using PostgreSQL LISTEN/NOTIFY as an Alternative/Bridge for Kafka Functionality Surafel Temesgen
• Clarification request: Kafka 3.7 to 4.2 rolling upgrade order for KRaft controllers and brokers Alireza Asgarian
• [jira] [Resolved] (KAFKA-20574) SimpleConfigRepository in the storage module could be replaced by MockConfigRepository Chia-Ping Tsai (Jira)
• Re: [DISCUSS] KIP-1272: Support compacted topic in tiered storage Luke Chen
  • Re: [DISCUSS] KIP-1272: Support compacted topic in tiered storage Henry Haiying Cai via dev
  • Re: [DISCUSS] KIP-1272: Support compacted topic in tiered storage Luke Chen
• [jira] [Resolved] (KAFKA-20443) Move RequestChannel Requests to server module Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20591) Document restore.buffered.records.per.partition in Streams developer guide Muralidhar Basani (Jira)
• [jira] [Created] (KAFKA-20590) Add integration test coverage for restore.buffered.records.per.partition cap Muralidhar Basani (Jira)
• [jira] [Created] (KAFKA-20589) Add restore.buffered.records.per.partition config and enforce cap in StoreChangelogReader Muralidhar Basani (Jira)
• [jira] [Created] (KAFKA-20588) Add restore.buffered.records.per.partition to cap Kafka Streams state-restore memory Muralidhar Basani (Jira)
• [jira] [Created] (KAFKA-20587) Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams Muralidhar Basani (Jira)
• [jira] [Created] (KAFKA-20586) Flaky : LeaderElectionCommandTest > testPreferredReplicaElection [1] Type=Raft-Isolated, MetadataVersion=4.4-IV0 Muralidhar Basani (Jira)
• [jira] [Created] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse Shivsundar R (Jira)
• [jira] [Resolved] (KAFKA-20440) PEM certificate support should not depend on PKCS12 Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20584) issue in SASL oauthbearer flow for kraft version in kafka 4.2 Kalyan Ram chowdary purimetla (Jira)
• [PR] Add Sean Quah to committers.json [kafka-site] via GitHub
  • Re: [PR] Add Sean Quah to committers.json [kafka-site] via GitHub
  • Re: [PR] Add Sean Quah to committers.json [kafka-site] via GitHub
  • Re: [PR] Add Sean Quah to committers.json [kafka-site] via GitHub
  • Re: [PR] Add Sean Quah to committers.json [kafka-site] via GitHub
• [jira] [Created] (KAFKA-20583) KRaft controller does not support dynamic SSL certificate reload for CONTROLLER listener unlike broker listeners Swathi Mocharla (Jira)
• [jira] [Created] (KAFKA-20582) KRaft restart/restore instability when ACL enabled and CQ uses allow.everyone.if.no.acl.found=true without super.users Swathi Mocharla (Jira)
• [VOTE] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy 黃竣陽
  • Re:[VOTE] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy Ryan Leslie (BLOOMBERG/ NEW YORK) via dev
  • Re: [VOTE] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy 黃竣陽
  • Re: [VOTE] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy 黃竣陽
  • Re: [VOTE] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy Muralidhar Basani via dev
  • Re: [VOTE] KIP-1327 Prevent Hot Data Loss on Partition Expansion for Latest Policy Chia-Ping Tsai
• [VOTE] 4.2.1 RC5 PoAn Yang
  • Re: [kafka-clients] [VOTE] 4.2.1 RC5 Mickael Maison
  • Re: [kafka-clients] [VOTE] 4.2.1 RC5 Lucas Brutschy via dev
  • Re: [VOTE] 4.2.1 RC5 Jakub Scholz
• [jira] [Resolved] (KAFKA-20563) Flaky test ShareConsumerRackAwareTest.testShareConsumerWithRackAwareAssignor Andrew Schofield (Jira)
• [DISCUSS] KIP-1339: Make KafkaConfigBackingStore read_write_total_timeout configurable Henry Haiying Cai via dev
  • Re: [DISCUSS] KIP-1339: Make KafkaConfigBackingStore read_write_total_timeout configurable Chris Egerton
  • Re: [DISCUSS] KIP-1339: Make KafkaConfigBackingStore read_write_total_timeout configurable Henry Haiying Cai via dev
• [jira] [Resolved] (KAFKA-20488) KRaft migration rollback causes offline partitions when KRaft epoch exceeds ZK controller epoch Luke Chen (Jira)
• [VOTE] KIP-1325: Add restore.buffered.records.per.partition to cap Kafka Streams state-restore memory Muralidhar Basani via dev
  • Re: [VOTE] KIP-1325: Add restore.buffered.records.per.partition to cap Kafka Streams state-restore memory Chia-Ping Tsai
  • Re: [VOTE] KIP-1325: Add restore.buffered.records.per.partition to cap Kafka Streams state-restore memory Kamal Chandraprakash
  • Re: [VOTE] KIP-1325: Add restore.buffered.records.per.partition to cap Kafka Streams state-restore memory PoAn Yang
  • Re: [VOTE] KIP-1325: Add restore.buffered.records.per.partition to cap Kafka Streams state-restore memory Muralidhar Basani via dev
• [jira] [Created] (KAFKA-20581) Move MockAclMutator alongside AuthorizerTest, when AuthorizerTest is migrated out of core Muralidhar Basani (Jira)
• [jira] [Created] (KAFKA-20580) Scatter-gather support for producer dynamic allocation Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-20579) Implement dynamic allocation for compressed data Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-20578) Implement dynamic allocation for uncompressed data Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-20577) Producer configuration to define allocation strategy Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-20576) Dynamic memory allocation for the KafkaProducer Lianet Magrans (Jira)
• [PR] MINOR: Add blog post for 4.3.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add blog post for 4.3.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add blog post for 4.3.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add blog post for 4.3.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add blog post for 4.3.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add blog post for 4.3.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add blog post for 4.3.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add blog post for 4.3.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add blog post for 4.3.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add blog post for 4.3.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add blog post for 4.3.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add blog post for 4.3.0 [kafka-site] via GitHub
• [VOTE] 4.3.0 RC2 Mickael Maison
  • Re: [VOTE] 4.3.0 RC2 Andrew Schofield
  • Re: [VOTE] 4.3.0 RC2 Mickael Maison
  • Re: [VOTE] 4.3.0 RC2 Jakub Scholz
  • Re: [VOTE] 4.3.0 RC2 Lianet Magrans
  • Re: [VOTE] 4.3.0 RC2 Josep Prat via dev
  • Re: [VOTE] 4.3.0 RC2 Keith W
  • Re: [VOTE] 4.3.0 RC2 Federico Valeri
• 4.4.0 Release Manager Chia-Ping Tsai
  • Re: 4.4.0 Release Manager Omnia Ibrahim
  • Re: 4.4.0 Release Manager Lianet Magrans
  • Re: 4.4.0 Release Manager PoAn Yang
  • Re: 4.4.0 Release Manager 黃竣陽
  • Re: 4.4.0 Release Manager TaiJu Wu
  • Re: 4.4.0 Release Manager Muralidhar Basani via dev
  • Re: 4.4.0 Release Manager Ming-Yen Chung
  • Re: 4.4.0 Release Manager Christo Lolov
  • Re: 4.4.0 Release Manager Omnia Ibrahim
  • Re: 4.4.0 Release Manager Bill Bejeck
  • Re: 4.4.0 Release Manager Bill Bejeck
  • Re: 4.4.0 Release Manager o . g . h . ibrahim
  • Re: 4.4.0 Release Manager Lianet Magrans
  • Re: 4.4.0 Release Manager Bill Bejeck
  • Re: 4.4.0 Release Manager Lianet Magrans
  • Re: 4.4.0 Release Manager Omnia Ibrahim
  • Re: 4.4.0 Release Manager Matthias J. Sax
  • Re: 4.4.0 Release Manager o . g . h . ibrahim
  • Re: 4.4.0 Release Manager Maroš Orsák
  • Re: 4.4.0 Release Manager Matthias J. Sax
  • Re: 4.4.0 Release Manager Sahil Devgon
  • Re: 4.4.0 Release Manager Bill Bejeck
• [jira] [Resolved] (KAFKA-20572) Connect REST server throws NPE on startup when using listener-prefixed SSL configs Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20571) InMemory KeyValue store metric throws exception Matthias J. Sax (Jira)
• Re: [VOTE]: KIP-1071: Streams Rebalance Protocol Matthias J. Sax
• [jira] [Created] (KAFKA-20575) Add onPartitionsLost support for MockConsumer Aditya Kousik (Jira)
• [jira] [Created] (KAFKA-20574) SimpleConfigRepository in the storage module could be replaced by MockConfigRepository Muralidhar Basani (Jira)
• [DISCUSS] KIP-1338: Structured MDC Context for Kafka Logging Haifeng Chen
• [jira] [Created] (KAFKA-20573) KIP-1338: Structured MDC Context for Kafka Logging Haifeng Chen (Jira)
• [jira] [Created] (KAFKA-20572) Connect REST server throws NPE on startup when using listener-prefixed SSL configs Hector Geraldino (Jira)
• [jira] [Created] (KAFKA-20571) InMemory KeyValue store metric throws exception Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-20570) Catch RuntimeException in ConsumerProtocol deserialization in group coordinator Dongnuo Lyu (Jira)
• [PR] KAFKA-20488: KRaft migration rollback causes offline partitions when KRaft epoch exceeds ZK controller epoch [kafka-site] via GitHub
  • Re: [PR] KAFKA-20488: KRaft migration rollback causes offline partitions when KRaft epoch exceeds ZK controller epoch [kafka-site] via GitHub
• [VOTE] 4.2.1 RC4 PoAn Yang
  • Re: [kafka-clients] [VOTE] 4.2.1 RC4 Lucas Brutschy via dev
  • Re: [kafka-clients] [VOTE] 4.2.1 RC4 Josep Prat via dev
  • Re: [VOTE] 4.2.1 RC4 Chia-Ping Tsai
• [jira] [Created] (KAFKA-20569) Doc doesn't have upgrading steps Luke Chen (Jira)
• [jira] [Created] (KAFKA-20568) Unify DSL Store Accessor and Header-Aware Builder Naming Alieh Saeedi (Jira)
• [jira] [Resolved] (KAFKA-20285) Mpve UncleanLeaderElectionTest to server module Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20567) Skip loading UnifiedLog for stray replicas during broker startup Chia-Ping Tsai (Jira)
• [PR] Bump npm-check-updates from 21.0.3 to 22.2.0 [kafka-site] via GitHub
  • Re: [PR] Bump npm-check-updates from 21.0.3 to 22.2.0 [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-12928) Add a check whether the Task's statestore is actually a directory Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-19594) Multiple-partition topic support for TopologyTestDriver Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20566) Share group deletion in performance test sometimes gets stuck Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-20565) Flaky testAutoCommitSentBeforePositionUpdate Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-20564) Move AuthorizerTest to server module Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-20535) Investigate potential improvements to async consumer CPU usage under low max.poll.records Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-20563) Flaky test ShareConsumerRackAwareTest.testShareConsumerWithRackAwareAssignor Sushant Mahajan (Jira)
• [DISCUSS] KIP-1337: Add Protobuf MessageFormatter for Kafka Console Consumer Sruthi Sathyamoorthy
  • Re: [DISCUSS] KIP-1337: Add Protobuf MessageFormatter for Kafka Console Consumer Sruthi Sathyamoorthy
  • Re: [DISCUSS] KIP-1337: Add Protobuf MessageFormatter for Kafka Console Consumer Andrew Schofield
• Requesting permissions for new contributor for a KIP Sruthi Sathyamoorthy
  • Re: Requesting permissions for new contributor for a KIP Chia-Ping Tsai
• [jira] [Resolved] (KAFKA-20550) Rename OffsetsUtils to OffsetManager (or OffsetResetService) Chia-Ping Tsai (Jira)
• [VOTE] KIP-1301: Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` Nick Guo
  • Re: [VOTE] KIP-1301: Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` Chia-Ping Tsai
  • Re: [VOTE] KIP-1301: Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` Chia-Ping Tsai
  • Re: [VOTE] KIP-1301: Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` 黃竣陽
  • Re: [VOTE] KIP-1301: Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` David Jacot via dev
  • Re: [VOTE] KIP-1301: Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` Sean Quah via dev
• [jira] [Resolved] (KAFKA-18447) Support SASL_SSL protocol with java.security.auth.login.config Igor Soarez (Jira)
• [jira] [Resolved] (KAFKA-20523) Class name mismatch for LoggerFactory.getLogger method in KStreamKTableJoinProcessor.java Gavin Wang (Jira)
• [jira] [Resolved] (KAFKA-17715) Remove `force_use_zk_connection` from e2e Ming-Yen Chung (Jira)
• Request for code review KIP-1209 Anton Liauchuk
• [jira] [Resolved] (KAFKA-20114) Fix race between requestInFlight and backoffDeadlineMs in RPCProducerIdManager causing premature retries Sean Quah (Jira)
• [jira] [Resolved] (KAFKA-20558) NPE in ClusterInstance.waitUntilLeaderIsElectedOrChanged causes flaky tests Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19807) Add RPC-level integration tests for StreamsGroupHeartbeat Lucy Liu (Jira)
• Requesting permissions for new contributor Sruthi Sathyamoorthy
• [jira] [Created] (KAFKA-20562) Align StreamsGroup dynamic member updates with KIP-1071 epoch bump rules sanghyeok An (Jira)

• Earlier messages
• Later messages