dev  

Messages by Thread

• [GitHub] [kafka-site] mumrah opened a new pull request, #445: Pre-release of Kafka 3.3 documentation GitBox
  • [GitHub] [kafka-site] mumrah commented on pull request #445: Pre-release of Kafka 3.3 documentation GitBox
  • [GitHub] [kafka-site] mumrah merged pull request #445: Pre-release of Kafka 3.3 documentation GitBox
• PR for CVE-2022-34917 Swathi Mocharla
  • Re: PR for CVE-2022-34917 Manikumar
  • Re: PR for CVE-2022-34917 Tom Bentley
• Regarding Contribution to Kafka. Vimal K
  • Re: Regarding Contribution to Kafka. Luke Chen
• [DISCUSS] solutions for broker OOM caused by many producer IDs Luke Chen
• [DISCUSS] KIP-872: Add Serializer#serializeToByteBuffer() to reduce memory copying ShunKang Lin
• [DISCUSS] KIP-871: Fix ByteBufferSerializer#serialize(String, ByteBuffer) compatible problem ShunKang Lin
• [jira] [Resolved] (KAFKA-14043) The latest status of the task is overwritten by the old status doupengwei (Jira)
• [jira] [Created] (KAFKA-14260) InMemoryKeyValueStore iterator still throws ConcurrentModificationException Avi Cherry (Jira)
• Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.3 #83 Apache Jenkins Server
  • Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #84 Apache Jenkins Server
  • Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.3 #85 Apache Jenkins Server
• [jira] [Created] (KAFKA-14259) BrokerRegistration#toString throws an exception, terminating metadata replay Colin McCabe (Jira)
• [jira] [Created] (KAFKA-14258) Add ducktape or junit test verifying that brokers can reload snapshots after startup Colin McCabe (Jira)
• [jira] [Created] (KAFKA-14257) Unexpected error INCONSISTENT_CLUSTER_ID in VOTE response jianbin.chen (Jira)
  • Re: [jira] [Created] (KAFKA-14257) Unexpected error INCONSISTENT_CLUSTER_ID in VOTE response deng ziming
• [VOTE] KIP-863: Reduce Fetcher#parseRecord() memory copy ShunKang Lin
  • Re: [VOTE] KIP-863: Reduce Fetcher#parseRecord() memory copy Guozhang Wang
• [jira] [Created] (KAFKA-14256) Update to Scala 2.13.9 Matthew de Detrich (Jira)
• [jira] [Created] (KAFKA-14255) Fetching from follower should be disallowed if fetch from follower is disabled David Jacot (Jira)
• Re: [VOTE] KIP-792: Add "generation" field into consumer protocol David Jacot
  • Re: [VOTE] KIP-792: Add "generation" field into consumer protocol Luke Chen
  • Re: [VOTE] KIP-792: Add "generation" field into consumer protocol David Jacot
• [jira] [Resolved] (KAFKA-14236) ListGroups request produces too much Denied logs in authorizer Jason Gustafson (Jira)
• [jira] [Created] (KAFKA-14254) Format timestamps in assignor logs as dates instead of integers John Roesler (Jira)
• [jira] [Created] (KAFKA-14253) StreamsPartitionAssignor should print the member count in assignment logs John Roesler (Jira)
• [jira] [Created] (KAFKA-14252) Create background thread skeleton Philip Nee (Jira)
• [jira] [Created] (KAFKA-14251) Improve CPU usage of self-joins by sacrificing order Vicky Papavasileiou (Jira)
• [jira] [Created] (KAFKA-14250) Exception during normal operation in MirrorSourceTask causes the task to fail instead of shutting down gracefully Viktor Somogyi-Vass (Jira)
• [DISCUSS] KIP-870: Retention policy based on record event time Николай Ижиков
• [jira] [Created] (KAFKA-14249) Flaky test Tls13SelectorTest. testCloseOldestConnection Divij Vaidya (Jira)
• [jira] [Created] (KAFKA-14248) Flaky test PlaintextAdminIntegrationTest.testCreateTopicsReturnsConfigs Divij Vaidya (Jira)
• [VOTE] 3.3.0 RC2 David Arthur
  • Re: [VOTE] 3.3.0 RC2 Josep Prat
  • Re: [kafka-clients] Re: [VOTE] 3.3.0 RC2 David Arthur
  • Re: [kafka-clients] Re: [VOTE] 3.3.0 RC2 David Arthur
• [jira] [Resolved] (KAFKA-14214) StandardAuthorizer may transiently process ACLs out of write order David Arthur (Jira)
• [jira] [Resolved] (KAFKA-14243) Temporarily disable unsafe downgrade David Arthur (Jira)
• Delete quota node in zookeeper when configs are empty Junyang Liu
  • Re: Delete quota node in zookeeper when configs are empty Luke Chen
• [jira] [Created] (KAFKA-14247) Implement EventHandler interface and DefaultEventHandler Philip Nee (Jira)
• [jira] [Created] (KAFKA-14246) Refactor KafkaConsumer Threading Model Philip Nee (Jira)
• [jira] [Created] (KAFKA-14245) Topic deleted during reassignment Junyang Liu (Jira)
• Testing Kafka on laptop vinoth rajagopalan
• Maximum Number of Streams In KSQL Join Tim McClure
• [jira] [Created] (KAFKA-14244) Prevent unit/integration tests from terminating JVM Chris Egerton (Jira)
• [GitHub] [kafka-site] tombentley merged pull request #444: MINOR: Mention CVE-2022-34917 in downloads.html GitBox
• [jira] [Resolved] (KAFKA-14212) Fetch error response when hitting public OAuth/OIDC provider Manikumar (Jira)
• Improve connection limit of coordinator and fetch leader thought126
• [jira] [Created] (KAFKA-14243) Disable unsafe downgrade in 3.3 Colin McCabe (Jira)
• [jira] [Resolved] (KAFKA-14240) Ensure kraft metadata log dir is initialized with valid snapshot state Jason Gustafson (Jira)
• [GitHub] [kafka-site] AlecGoncharow opened a new pull request, #443: Update Cloudflare section GitBox
• [jira] [Resolved] (KAFKA-12878) Support --bootstrap-server kafka-streams-application-reset Chris Egerton (Jira)
• [jira] [Resolved] (KAFKA-14063) Kafka message parsing can cause ooms with small antagonistic payloads Manikumar (Jira)
• Request for contribution to Kafka Muralidhar Basani
  • Re: Request for contribution to Kafka Chris Egerton
• CVE-2022-34917: Unauthenticated clients may cause OutOfMemoryError on Apache Kafka Brokers Manikumar
  • Re: CVE-2022-34917: Unauthenticated clients may cause OutOfMemoryError on Apache Kafka Brokers Luke Chen
  • CVE-2022-34917: Unauthenticated clients may cause OutOfMemoryError on Apache Kafka Brokers Manikumar
• [ANNOUNCE] Apache Kafka 3.2.3 Manikumar
• [ANNOUNCE] Apache Kafka 3.1.2 Manikumar
• [ANNOUNCE] Apache Kafka 3.0.2 Manikumar
• [ANNOUNCE] Apache Kafka 2.8.2 Manikumar
• Contributor Access Request Ahmed Sobeh
  • Re: Contributor Access Request Chris Egerton
• [GitHub] [kafka-site] omkreddy merged pull request #442: download.html and javadocs updates for 3.0.2, 3.1.2 and 3.2.3 GitBox
• [jira] [Created] (KAFKA-14242) Hanging logManager in testReloadUpdatedFilesWithoutConfigChange test Luke Chen (Jira)
• [jira] [Resolved] (KAFKA-14238) KRaft replicas can delete segments not included in a snapshot Jason Gustafson (Jira)
• [jira] [Created] (KAFKA-14241) Implement the snapshot cleanup policy Jose Armando Garcia Sancio (Jira)
• [jira] [Created] (KAFKA-14240) Ensure kraft metadata log dir is initialized with valid snapshot state Jason Gustafson (Jira)
• Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.2 #85 Apache Jenkins Server
• [DISCUSS] KIP-869: Improve Streams State Restoration Visibility Guozhang Wang
  • Re: [DISCUSS] KIP-869: Improve Streams State Restoration Visibility Bruno Cadonna
  • Re: [DISCUSS] KIP-869: Improve Streams State Restoration Visibility Guozhang Wang
  • Re: [DISCUSS] KIP-869: Improve Streams State Restoration Visibility Nick Telford
  • Re: [DISCUSS] KIP-869: Improve Streams State Restoration Visibility Guozhang Wang
  • Re: [DISCUSS] KIP-869: Improve Streams State Restoration Visibility Guozhang Wang
  • Re: [DISCUSS] KIP-869: Improve Streams State Restoration Visibility Bruno Cadonna
• [jira] [Created] (KAFKA-14239) Merge StateRestorationIntegrationTest into RestoreIntegrationTest Guozhang Wang (Jira)
• [jira] [Created] (KAFKA-14238) KRaft replicas can delete segments not included in a snapshot Jose Armando Garcia Sancio (Jira)
• [jira] [Created] (KAFKA-14237) Kafka TLS Doesn't Present Intermediary Certificates when using PEM Ryan R (Jira)
• Request for contributor permissions Akshay Bhadange
  • Re: Request for contributor permissions Guozhang Wang
  • Request for contributor permissions Christopher Razavian
  • Re: Request for contributor permissions Chris Egerton
  • Re: Request for contributor permissions Christopher Razavian
• [jira] [Created] (KAFKA-14236) ListGroups request produces too much Denied logs in authorizer Alexandre GRIFFAUT (Jira)
• [jira] [Resolved] (KAFKA-13840) KafkaConsumer is unable to recover connection to group coordinator after commitOffsetsAsync exception Luke Chen (Jira)
• [jira] [Created] (KAFKA-14235) Document MM2 auto topic creation behavior for MM2-internal topics Maruthi (Jira)
• [jira] [Resolved] (KAFKA-13632) MirrorMaker 2.0 NPE and Warning "Failure to commit records" for filtered records Chris Egerton (Jira)
• [jira] [Resolved] (KAFKA-13985) MirrorSourceTask commitRecord throws NPE if SMT is filtering out source record Chris Egerton (Jira)
• [jira] [Reopened] (KAFKA-7109) KafkaConsumer should close its incremental fetch sessions on close Luke Chen (Jira)
• [jira] [Resolved] (KAFKA-14156) Built-in partitioner may create suboptimal batches with large linger.ms Jun Rao (Jira)
• [jira] [Created] (KAFKA-14234) /admin/delete_topics is not in the list of zookeeper watchers Yan Xue (Jira)
• Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #75 Apache Jenkins Server
  • Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #76 Apache Jenkins Server
  • Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #77 Apache Jenkins Server
  • Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #78 Apache Jenkins Server
• [GitHub] [kafka-site] HilmiEgemenCiritoglu opened a new pull request, #441: Correct the year of release date for 2.7.1 in downloads.html GitBox
• [GitHub] [kafka-site] HilmiEgemenCiritoglu opened a new pull request, #440: Updated powered-by page for Criteo usage GitBox
  • [GitHub] [kafka-site] bbejeck merged pull request #440: Updated powered-by page for Criteo usage GitBox
  • [GitHub] [kafka-site] bbejeck commented on pull request #440: Updated powered-by page for Criteo usage GitBox
  • [GitHub] [kafka-site] HilmiEgemenCiritoglu commented on pull request #440: Updated powered-by page for Criteo usage GitBox
• [jira] [Created] (KAFKA-14233) Jenkins build failed with task ':core:unitTest' exit value 1 Luke Chen (Jira)
• [jira] [Resolved] (KAFKA-14220) "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing. Pritam Kumar (Jira)
• [jira] [Created] (KAFKA-14232) Support for nested structures: InsertField Jorge Esteban Quilcate Otoya (Jira)
• [jira] [Created] (KAFKA-14231) Support for nested structures: ReplaceField Jorge Esteban Quilcate Otoya (Jira)
• [jira] [Created] (KAFKA-14230) Support for nested structures: Cast Jorge Esteban Quilcate Otoya (Jira)
• [jira] [Created] (KAFKA-14228) Support for nested structures: ValueToKey Jorge Esteban Quilcate Otoya (Jira)
• [jira] [Created] (KAFKA-14229) Support for nested structures: HoistValue Jorge Esteban Quilcate Otoya (Jira)
• [jira] [Created] (KAFKA-14227) Support for nested structures: MaskField Jorge Esteban Quilcate Otoya (Jira)
• [jira] [Created] (KAFKA-14226) Introduce support for nested structures Jorge Esteban Quilcate Otoya (Jira)
• KafkaConsumer refactor proposal Philip Nee
  • Re: KafkaConsumer refactor proposal Kirk True
  • Re: KafkaConsumer refactor proposal Philip Nee
  • Re: KafkaConsumer refactor proposal Guozhang Wang
  • Re: KafkaConsumer refactor proposal Philip Nee
  • Re: KafkaConsumer refactor proposal Guozhang Wang
  • Re: KafkaConsumer refactor proposal Philip Nee
  • Re: KafkaConsumer refactor proposal Luke Chen
  • Re: KafkaConsumer refactor proposal Philip Nee
• [jira] [Created] (KAFKA-14225) lazy val exemptSensor Could Cause Deadlock Huilin Shi (Jira)
• [jira] [Resolved] (KAFKA-14073) Logging the reason for creating a snapshot Jose Armando Garcia Sancio (Jira)
• [jira] [Resolved] (KAFKA-14196) Duplicated consumption during rebalance, causing OffsetValidationTest to act flaky Luke Chen (Jira)
• [jira] [Resolved] (KAFKA-14208) KafkaConsumer#commitAsync throws unexpected WakeupException Luke Chen (Jira)
• [jira] [Resolved] (KAFKA-14215) KRaft forwarded requests have no quota enforcement Jason Gustafson (Jira)
• Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #68 Apache Jenkins Server
  • Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #69 Apache Jenkins Server
  • Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #70 Apache Jenkins Server
  • Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #71 Apache Jenkins Server
  • Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #72 Apache Jenkins Server
  • Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #73 Apache Jenkins Server
• [jira] [Created] (KAFKA-14224) Consumer should auto-commit prior to cooperative partition revocation Jason Gustafson (Jira)
• [jira] [Resolved] (KAFKA-14223) Update jdk_17_latest to adoptium 17.0.4+1 Matthew de Detrich (Jira)
• [jira] [Created] (KAFKA-14223) Update jdk_17_latest to adoptium 17.0.4+1 Matthew de Detrich (Jira)
• [jira] [Created] (KAFKA-14222) Exhausted BatchMemoryPool Jose Armando Garcia Sancio (Jira)
• [jira] [Resolved] (KAFKA-14216) Remove ZK reference from org.apache.kafka.server.quota.ClientQuotaCallback javadoc Colin McCabe (Jira)
• [jira] [Resolved] (KAFKA-14217) app-reset-tool.html should remove reference to --zookeeper flag that no longer exists Colin McCabe (Jira)
• [jira] [Created] (KAFKA-14221) Update Apache Kafka JVM version in CI to latest versions Matthew de Detrich (Jira)
• [jira] [Created] (KAFKA-14220) "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing. Pritam Kumar (Jira)
• [VOTE] Jorge Esteban Quilcate Otoya
  • Re: [VOTE] KIP-864: Add End-To-End Latency Metrics to Connectors Jorge Esteban Quilcate Otoya
  • Re: [VOTE] KIP-864: Add End-To-End Latency Metrics to Connectors Yash Mayya
• [jira] [Created] (KAFKA-14219) Kafka messages are not read in certain bytes or message count in batches when read from Spark Madhav Madhu (Jira)
• [jira] [Created] (KAFKA-14218) replace temp file handler with JUnit 5 Temporary Directory Support Luke Chen (Jira)
• [jira] [Created] (KAFKA-14217) app-reset-tool.html should remove reference to --zookeeper flag that no longer exists Colin McCabe (Jira)
• [jira] [Created] (KAFKA-14216) Remove ZK reference from org.apache.kafka.server.quota.ClientQuotaCallback javadoc Colin McCabe (Jira)
• [jira] [Created] (KAFKA-14215) KRaft forwarded requests have no quota enforcement Jason Gustafson (Jira)
• [jira] [Created] (KAFKA-14214) StandardAuthorizer may transiently process ACLs out of write order Akhilesh Chaganti (Jira)
• Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.2 #81 Apache Jenkins Server
• Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #65 Apache Jenkins Server
  • Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #66 Apache Jenkins Server
• [DISCUSS] KIP-868 Metadata Transactions (new thread) David Arthur
  • Re: [DISCUSS] KIP-868 Metadata Transactions (new thread) Luke Chen
  • Re: [DISCUSS] KIP-868 Metadata Transactions (new thread) David Arthur
  • Re: [DISCUSS] KIP-868 Metadata Transactions (new thread) deng ziming
  • Re: [DISCUSS] KIP-868 Metadata Transactions (new thread) David Arthur
  • Re: [DISCUSS] KIP-868 Metadata Transactions (new thread) deng ziming
• [VOTE] KIP-865: Support --bootstrap-server in kafka-streams-application-reset Николай Ижиков
  • Re: [VOTE] KIP-865: Support --bootstrap-server in kafka-streams-application-reset Guozhang Wang
  • Re: [VOTE] KIP-865: Support --bootstrap-server in kafka-streams-application-reset Николай Ижиков
  • Re: [VOTE] KIP-865: Support --bootstrap-server in kafka-streams-application-reset Bill Bejeck
  • Re: [VOTE] KIP-865: Support --bootstrap-server in kafka-streams-application-reset Chris Egerton
  • Re: [VOTE] KIP-865: Support --bootstrap-server in kafka-streams-application-reset Nikolay Izhikov
  • Re: [VOTE] KIP-865: Support --bootstrap-server in kafka-streams-application-reset Nikolay Izhikov
  • Re: [VOTE] KIP-865: Support --bootstrap-server in kafka-streams-application-reset Николай Ижиков
• [jira] [Created] (KAFKA-14213) Reduce lock contention between control-plane-kafka-request-handler and kafka-log-cleaner-thread Lucas Wang (Jira)
• [jira] [Created] (KAFKA-14212) Fetch error response when hitting public OAuth/OIDC provider Sushant Mahajan (Jira)
• [DISCUSS] KIP-865 Metadata Transactions David Arthur
  • Re: [DISCUSS] KIP-865 Metadata Transactions Colin McCabe
  • Re: [DISCUSS] KIP-865 Metadata Transactions Николай Ижиков
  • Re: [DISCUSS] KIP-865 Metadata Transactions Colin McCabe
  • Re: [DISCUSS] KIP-865 Metadata Transactions David Arthur
• [jira] [Created] (KAFKA-14211) Streams log message has partition and offset transposed Matt Allwood (Jira)
• [VOTE] KIP-848: The Next Generation of the Consumer Rebalance Protocol David Jacot
  • Re: [VOTE] KIP-848: The Next Generation of the Consumer Rebalance Protocol Guozhang Wang
  • Re:[VOTE] KIP-848: The Next Generation of the Consumer Rebalance Protocol Hector Geraldino (BLOOMBERG/ 919 3RD A)
• [jira] [Resolved] (KAFKA-14210) <default> client quota config key is sanitized in Kraft broker dengziming (Jira)
• [jira] [Created] (KAFKA-14210) <default> client quota config key is sanitized in Kraft broker dengziming (Jira)
• [jira] [Resolved] (KAFKA-14204) QuorumController must correctly handle overly large batches Jose Armando Garcia Sancio (Jira)
• [jira] [Resolved] (KAFKA-14143) Exactly-once source system tests Chris Egerton (Jira)
• [VOTE] KIP-862: Self-join optimization for stream-stream joins Vasiliki Papavasileiou
  • Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins Guozhang Wang
  • Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins Vasiliki Papavasileiou
  • Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins Guozhang Wang
  • Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins Vasiliki Papavasileiou
  • Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins John Roesler
  • Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins Guozhang Wang
  • Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins Jim Hughes
  • Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins Bruno Cadonna
  • Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins Vasiliki Papavasileiou
• [jira] [Created] (KAFKA-14209) Optimize stream stream self join to use single state store Vicky Papavasileiou (Jira)
• Bug fix for KAFKA-13927 Jordan Bull
• [jira] [Resolved] (KAFKA-13952) Infinite retry timeout is not working Chris Egerton (Jira)
• [jira] [Created] (KAFKA-14208) KafkaConsumer#commitAsync throws unexpected WakeupException Qingsheng Ren (Jira)
• [jira] [Created] (KAFKA-14207) Add a 6.10 section for KRaft Jose Armando Garcia Sancio (Jira)

• Earlier messages