dev  

Messages by Thread

• [DISCUSS] KIP-404: Add Kafka Connect configuration parameter for disabling WADL output on OPTIONS request Oleksandr Diachenko
  • Re: [DISCUSS] KIP-404: Add Kafka Connect configuration parameter for disabling WADL output on OPTIONS request Guozhang Wang
• [jira] [Resolved] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic Guozhang Wang (JIRA)
• Kafka Trunk Build Failure with Gradle 5.0 Boyang Chen
  • Re: Kafka Trunk Build Failure with Gradle 5.0 Guozhang Wang
• [jira] [Resolved] (KAFKA-7712) Handle exceptions from immediately connected channels in Selector Jason Gustafson (JIRA)
• [jira] [Resolved] (KAFKA-7705) Update javadoc for the values of delivery.timeout.ms or linger.ms Jason Gustafson (JIRA)
• [VOTE] KIP-381 Connect: Tell about records that had their offsets flushed in callback Per Steffensen
• Permissions to edit KIP page and ... Per Steffensen
  • Re: Permissions to edit KIP page and ... Manikumar
• [jira] [Created] (KAFKA-7727) kafka-producer-network-thread throwing Error: NOT_LEADER_FOR_PARTITION after adding new broker to kafka cluster venkatakumar puvvada (JIRA)
• [jira] [Created] (KAFKA-7726) Connector status on deletion Eyal Ringort (JIRA)
• [jira] [Reopened] (KAFKA-4790) Kafka cannot recover after a disk full Eno Thereska (JIRA)
• [jira] [Created] (KAFKA-7725) Add a delay for further CG rebalances, beyond KIP-134 group.initial.rebalance.delay.ms Antony Stubbs (JIRA)
• [jira] [Created] (KAFKA-7724) Docs for KIP-71 compact AND delete need correcting Antony Stubbs (JIRA)
• [jira] [Created] (KAFKA-7723) Kafka Connect support override worker kafka api configuration with connector configuration that post by rest api laomei (JIRA)
• [jira] [Created] (KAFKA-7722) Increase ProducerPerformance precision by using nanoTime Kevin Lu (JIRA)
• Reviewers for PR: Automatic unique client id option for Kafka Connect Paul Davidson
• RE: [VOTE] KIP-383 Pluggable interface for SSL Factory Pellerin, Clement
• [jira] [Created] (KAFKA-7721) Connection to zookeeper refused Mohammad Etemad (JIRA)
• Build failed in Jenkins: kafka-trunk-jdk8 #3254 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk8 #3255 Apache Jenkins Server
• [DISCUSS] KIP-402: Improve fairness in SocketServer processors Rajini Sivaram
  • Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors Harsha
  • Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors Rajini Sivaram
• [jira] [Created] (KAFKA-7720) kafka-configs script should also describe default broker entries Edoardo Comar (JIRA)
• [jira] [Created] (KAFKA-7719) Improve fairness in SocketServer processors Rajini Sivaram (JIRA)
• Build failed in Jenkins: kafka-2.1-jdk8 #79 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.1-jdk8 #80 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.1-jdk8 #81 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.1-jdk8 #82 Apache Jenkins Server
• Build failed in Jenkins: kafka-trunk-jdk11 #150 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk11 #151 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-7610) Detect consumer failures in initial JoinGroup Guozhang Wang (JIRA)
• [jira] [Created] (KAFKA-7718) Allow customized header inheritance for stateful operators in DSL Guozhang Wang (JIRA)
• [jira] [Resolved] (KAFKA-6036) Enable logical materialization to physical materialization Guozhang Wang (JIRA)
• [jira] [Created] (KAFKA-7717) Enable security configs in kafka.tools.EndToEndLatency Stanislav Kozlovski (JIRA)
• Finding reviewers for some fixes for sequenceId overflow Ming Liu
• Kafka client Metadata update on demand? Ming Liu
  • Re: Kafka client Metadata update on demand? Mayuresh Gharat
• [jira] [Resolved] (KAFKA-7549) Old ProduceRequest with zstd compression does not return error to client Jason Gustafson (JIRA)
• [jira] [Created] (KAFKA-7716) Unprocessed messages when Broker fails Finbarr Naughton (JIRA)
• Build failed in Jenkins: kafka-trunk-jdk11 #148 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk11 #149 Apache Jenkins Server
• [DISCUSS] KIP-401 TransformerSupplier/ProcessorSupplier enhancements Paul Whalen
  • Re: [DISCUSS] KIP-401 TransformerSupplier/ProcessorSupplier enhancements Guozhang Wang
  • Re: [DISCUSS] KIP-401 TransformerSupplier/ProcessorSupplier enhancements Paul Whalen
• contributor list david greenfield
  • Re: contributor list Matthias J. Sax
• [jira] [Created] (KAFKA-7715) Connect should have a parameter to disable WADL output for OPTIONS method Oleksandr Diachenko (JIRA)
• [DISCUSS]KIP-400:Add option in ConsoleProducer so user can decide how to handle errors kamal kaur
• [jira] [Created] (KAFKA-7714) Scala streams API should use Options in left and outer joins Charles Crain (JIRA)
• KIP creation permission Paul Whalen
  • Re: KIP creation permission Matthias J. Sax
• [NOTICE] Mandatory relocation of Apache git repositories on git-wip-us.apache.org Daniel Gruno
  • Re: [NOTICE] Mandatory relocation of Apache git repositories on git-wip-us.apache.org Ismael Juma
  • Re: [NOTICE] Mandatory relocation of Apache git repositories on git-wip-us.apache.org Daniel Gruno
  • Re: [NOTICE] Mandatory relocation of Apache git repositories on git-wip-us.apache.org Ismael Juma
  • Re: [NOTICE] Mandatory relocation of Apache git repositories on git-wip-us.apache.org Christopher
• [jira] [Created] (KAFKA-7713) producer io-wait-ratio > 1 dan norwood (JIRA)
• [jira] [Created] (KAFKA-7712) Handle exceptions from immediately connected channels in Selector Rajini Sivaram (JIRA)
• DisconnectException stop Kafka Stream app consuming from topic Jonathan Santilli
• Finding reviewrs for a Kafka issue fix lk gen
  • Re: Finding reviewrs for a Kafka issue fix Gwen Shapira
  • Re: Finding reviewrs for a Kafka issue fix lk gen
  • Re: Finding reviewrs for a Kafka issue fix Vahid Hashemian
• Kafka Cluster Setup Abhimanyu Nagrath
  • Re: Kafka Cluster Setup Vahid Hashemian
  • Re: Kafka Cluster Setup Abhimanyu Nagrath
  • Re: Kafka Cluster Setup Abhimanyu Nagrath
  • Re: Kafka Cluster Setup Suman B N
  • Re: Kafka Cluster Setup Vahid Hashemian
• Build failed in Jenkins: kafka-trunk-jdk8 #3247 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #3248 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #3249 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #3250 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #3251 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #3252 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk8 #3253 Apache Jenkins Server
• Build failed in Jenkins: kafka-trunk-jdk11 #144 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk11 #145 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-7709) ConcurrentModificationException occurs when iterating through multiple partitions in Sender.getExpiredInflightBatches Guozhang Wang (JIRA)
• [jira] [Created] (KAFKA-7711) Add a bounded flush() API to Kafka Producer kun du (JIRA)
• Kafka replication error Suman B N
  • Re: Kafka replication error Suman B N
  • Re: Kafka replication error Suman B N
  • Re: Kafka replication error Suman B N
  • Re: Kafka replication error Tony Liu
  • Re: Kafka replication error Suman B N
  • Re: Kafka replication error Tony Liu
• [jira] [Resolved] (KAFKA-7704) kafka.server.ReplicaFetechManager.MaxLag.Replica metric is reported incorrectly Jun Rao (JIRA)
• Build failed in Jenkins: kafka-2.1-jdk8 #75 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-2.1-jdk8 #76 Apache Jenkins Server
• [jira] [Created] (KAFKA-7710) Poor Zookeeper ACL management with Kerberos Mr Kafka (JIRA)
• Kafka 1.1.0 no longer available for download? David Glasser
  • Re: Kafka 1.1.0 no longer available for download? David Glasser
  • Re: Kafka 1.1.0 no longer available for download? Harsha
• [jira] [Resolved] (KAFKA-7673) Upgrade RocksDB to include fix for WinEnvIO::GetSectorSize Guozhang Wang (JIRA)
• Build failed in Jenkins: kafka-1.1-jdk7 #235 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-1.1-jdk7 #236 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-6388) Error while trying to roll a segment that already exists Jason Gustafson (JIRA)
• Build failed in Jenkins: kafka-2.0-jdk8 #198 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.0-jdk8 #199 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.0-jdk8 #200 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.0-jdk8 #201 Apache Jenkins Server
• Build failed in Jenkins: kafka-2.1-jdk8 #73 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-2.1-jdk8 #74 Apache Jenkins Server
• [jira] [Created] (KAFKA-7709) ConcurrentModificationException occurs when iterating through multiple partitions in Sender.getExpiredInflightBatches Mark Cho (JIRA)
• Kafka Help kalpana more
  • Re: Kafka Help Matthias J. Sax
• Vote for KIP-393 (Fix time windowed serde to deserialize changelog topic) Shawn Nguyen
  • Re: Vote for KIP-393 (Fix time windowed serde to deserialize changelog topic) Guozhang Wang
  • Re: Vote for KIP-393 (Fix time windowed serde to deserialize changelog topic) Liquan Pei
  • Re: Vote for KIP-393 (Fix time windowed serde to deserialize changelog topic) Boyang Chen
  • Re: Vote for KIP-393 (Fix time windowed serde to deserialize changelog topic) Shawn Nguyen
  • Re: Vote for KIP-393 (Fix time windowed serde to deserialize changelog topic) Adam Bellemare
• [jira] [Created] (KAFKA-7708) [kafka-streams-scala] Invalid signature for KTable join in 2.12 Edmondo Porcu (JIRA)
• [jira] [Resolved] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition Rajini Sivaram (JIRA)
• [VOTE] KIP-394: Require member.id for initial join group request Boyang Chen
  • Re: [VOTE] KIP-394: Require member.id for initial join group request Mayuresh Gharat
  • Re: [VOTE] KIP-394: Require member.id for initial join group request Matthias J. Sax
  • Re: [VOTE] KIP-394: Require member.id for initial join group request Bill Bejeck
  • Re: [VOTE] KIP-394: Require member.id for initial join group request Boyang Chen
  • Re: [VOTE] KIP-394: Require member.id for initial join group request Jason Gustafson
  • Re: [VOTE] KIP-394: Require member.id for initial join group request Guozhang Wang
  • Re: [VOTE] KIP-394: Require member.id for initial join group request Harsha
  • Re: [VOTE] KIP-394: Require member.id for initial join group request Boyang Chen
• Problem with Kafka Connector Федор Чернилин
• [jira] [Created] (KAFKA-7707) Some code is not necessary huangyiming (JIRA)
• [jira] [Created] (KAFKA-7706) Spotbugs task fails with Gradle 5.0 FuQiao Wang (JIRA)
• Build failed in Jenkins: kafka-trunk-jdk8 #3241 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #3242 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #3243 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #3244 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk8 #3245 Apache Jenkins Server
• Kafka Summit NYC and London in 2019 Jun Rao
• [jira] [Resolved] (KAFKA-7687) Print batch level information in DumpLogSegments when deep iterating Jason Gustafson (JIRA)
• Build failed in Jenkins: kafka-trunk-jdk8 #3239 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk8 #3240 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-7696) kafka-delegation-tokens.sh using a config file that contains security.protocol=SASL_PLAINTEXT throws OutOfMemoryError if it tries to connect to an SSL-enabled secured broker Attila Sasvari (JIRA)
• Build failed in Jenkins: kafka-2.0-jdk8 #196 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-2.0-jdk8 #197 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-7702) Prefixed ACLs don't work with single character prefix Rajini Sivaram (JIRA)
• KAFKA-6144(or other ticket to resolve) Nikolay Izhikov
  • Re: KAFKA-6144(or other ticket to resolve) Matthias J. Sax
  • Re: KAFKA-6144(or other ticket to resolve) Nikolay Izhikov
• [jira] [Created] (KAFKA-7705) Update javadoc for default value of delivery.timeout.ms huxihx (JIRA)
• [jira] [Created] (KAFKA-7704) kafka.server.ReplicaFetechManager.MaxLag.Replica metric is reported incorrectly Yu Yang (JIRA)
• [jira] [Created] (KAFKA-7703) KafkaConsumer.position may return a wrong offset after "seekToEnd" is called Shixiong Zhu (JIRA)
• [jira] [Created] (KAFKA-7702) Prefixed ACLs don't work with single character prefix Rajini Sivaram (JIRA)
• [jira] [Created] (KAFKA-7701) Revert kafka-trunk-jdk8 CI change to re-enable testAll-based builds Colin Hicks (JIRA)
• [jira] [Created] (KAFKA-7700) AbstractConfig does not honor Properties defaults Tommy Becker (JIRA)
• [jira] [Created] (KAFKA-7699) Improve wall-clock time punctuations Matthias J. Sax (JIRA)
  • Re: [jira] [Created] (KAFKA-7699) Improve wall-clock time punctuations Patrick Williams
• [jira] [Created] (KAFKA-7698) Kafka Broker fail to start: ProducerFencedException thrown from producerstatemanager.scala!checkProducerEpoch Ming Liu (JIRA)
• [jira] [Created] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition Gian Merlino (JIRA)
• [jira] [Created] (KAFKA-7696) kafka-delegation-tokens.sh using a config file that contains security.protocol=SASL_PLAINTEXT throws OutOfMemoryError if it tries to connect to an SSL-enabled secured broker Attila Sasvari (JIRA)
• Re: [DISCUSS] KIP-201: Rationalising Policy interfaces Mickael Maison
  • Re: [DISCUSS] KIP-201: Rationalising Policy interfaces Tom Bentley
• [jira] [Created] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration Dmitry Buykin (JIRA)
• Build failed in Jenkins: kafka-0.10.2-jdk7 #240 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-0.10.2-jdk7 #241 Apache Jenkins Server
• Build failed in Jenkins: kafka-2.1-jdk8 #68 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-2.1-jdk8 #69 Apache Jenkins Server
• Build failed in Jenkins: kafka-0.11.0-jdk7 #409 Apache Jenkins Server
  • Build failed in Jenkins: kafka-0.11.0-jdk7 #410 Apache Jenkins Server
• [jira] [Created] (KAFKA-7694) Support ZooKeeper based master/secret key management for delegation tokens Manikumar (JIRA)
• [jira] [Resolved] (KAFKA-7235) Use brokerZkNodeVersion to prevent broker from processing outdated controller request Jun Rao (JIRA)
• [DISCUSS] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions Kamal Chandraprakash
  • Re: [DISCUSS] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions Matt Farmer
  • Re: [DISCUSS] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions Kamal Chandraprakash
  • Re: [DISCUSS] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions Matt Farmer
  • Re: [DISCUSS] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions Matthias J. Sax
  • Re: [DISCUSS] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions Kamal Chandraprakash
  • Re: [DISCUSS] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions Matthias J. Sax
  • Re: [DISCUSS] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions Kamal Chandraprakash
  • Re: [DISCUSS] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions Matt Farmer
• [jira] [Resolved] (KAFKA-1120) Controller could miss a broker state change Jun Rao (JIRA)
• [jira] [Created] (KAFKA-7692) updateFirstUnstableOffset NPE due to sequenceId overflow in ProducerStateManager.append Ming Liu (JIRA)
• [jira] [Created] (KAFKA-7693) "IllegalArgumentException: Invalid negative sequence number used" in Kafka Client Ming Liu (JIRA)
• [DISCUSS] KIP-395: Encypt-then-MAC Delegation token metadata Attila Sasvári
  • Re: [DISCUSS] KIP-395: Encypt-then-MAC Delegation token metadata Manikumar
  • Re: [DISCUSS] KIP-395: Encypt-then-MAC Delegation token metadata Satish Duggana
• [jira] [Resolved] (KAFKA-4219) Permit setting of event time in stream processor Guozhang Wang (JIRA)
• Build failed in Jenkins: kafka-trunk-jdk11 #130 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk11 #131 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk11 #132 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-7660) Stream Metrics - Memory Analysis Guozhang Wang (JIRA)
• [DISCUSS] KIP-398: Support reading trust store from classpath Noa Resare
  • Re: [DISCUSS] KIP-398: Support reading trust store from classpath Sönke Liebau
  • Re: [DISCUSS] KIP-398: Support reading trust store from classpath Rajini Sivaram
  • Re: [DISCUSS] KIP-398: Support reading trust store from classpath Noa Resare
  • Re: [DISCUSS] KIP-398: Support reading trust store from classpath Harsha
  • Re: [DISCUSS] KIP-398: Support reading trust store from classpath Noa Resare
• kafka?????????? ??????
• Heads up: spotBugs enabled for Java 11 builds Ismael Juma
• [DISCUSS] KIP-397: Add methods to override fetch offsets based on timestamp Brandon Kirchner
• [jira] [Resolved] (KAFKA-7676) Compile Kafka failed with Gradle 5.0 Ismael Juma (JIRA)
• [jira] [Created] (KAFKA-7691) Encypt-then-MAC Delegation token metadata Attila Sasvari (JIRA)
• [DISCUSS] KIP-396: Add Commit/List Offsets Operations to AdminClient Mickael Maison

• Earlier messages