dev  

Messages by Thread

• [jira] [Created] (KAFKA-10088) The ephemeral node [%s] at %s has gone away while reading it jinshaoling (Jira)
• [jira] [Created] (KAFKA-10087) Properly throw LogTruncation exception from OffsetForLeaderEpoch future Boyang Chen (Jira)
• [jira] [Resolved] (KAFKA-9945) TopicCommand should support --if-exists and --if-not-exists when --bootstrap-server is used Colin McCabe (Jira)
• [jira] [Created] (KAFKA-10086) Write Integration Test for StreamsTaskAssignor/HighAvailabilityTaskAssignor John Roesler (Jira)
• [jira] [Created] (KAFKA-10085) Compute lag correctly for optimized source changelogs Sophie Blee-Goldman (Jira)
• [jira] [Created] (KAFKA-10084) System test failure: StreamsEosTest.test_failure_and_recovery_complex John Roesler (Jira)
• [jira] [Resolved] (KAFKA-9987) Improve sticky partition assignor algorithm Sophie Blee-Goldman (Jira)
• [jira] [Resolved] (KAFKA-8723) flaky test LeaderElectionCommandTest#testAllTopicPartition Stanislav Kozlovski (Jira)
• [jira] [Created] (KAFKA-10083) fix failed testReassignmentWithRandomSubscriptionsAndChanges Luke Chen (Jira)
• [jira] [Created] (KAFKA-10082) fix failed kafka.api.PlaintextConsumerTest.testMultiConsumerStickyAssignment Luke Chen (Jira)
• Build failed in Jenkins: kafka-2.6-jdk8 #8 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.6-jdk8 #9 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.6-jdk8 #10 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.6-jdk8 #11 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.6-jdk8 #12 Apache Jenkins Server
• [jira] [Created] (KAFKA-10081) Execution failed for task ':clients:spotbugsMain' in recent build Luke Chen (Jira)
• Build failed in Jenkins: kafka-2.4-jdk8 #217 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.4-jdk8 #218 Apache Jenkins Server
• [jira] [Created] (KAFKA-10080) IllegalStateException after duplicate CompleteCommit append to transaction log Jason Gustafson (Jira)
• [jira] [Resolved] (KAFKA-10030) Throw exception while fetching a key from a single partition Matthias J. Sax (Jira)
• Build failed in Jenkins: kafka-trunk-jdk14 #153 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk14 #154 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk14 #155 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk14 #156 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk14 #157 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk14 #158 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk14 #159 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk14 #160 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk14 #161 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk14 #162 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk14 #163 Apache Jenkins Server
• Build failed in Jenkins: kafka-trunk-jdk11 #1522 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk11 #1523 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk11 #1524 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk11 #1525 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk11 #1526 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk11 #1527 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk11 #1528 Apache Jenkins Server
• Build failed in Jenkins: kafka-trunk-jdk8 #4595 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4596 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4597 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4598 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4599 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4600 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4601 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4602 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4603 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-10064) Add documentation for KIP-571 Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-10079) Support high availability for in-memory stores Sophie Blee-Goldman (Jira)
• [jira] [Resolved] (KAFKA-9821) Stream task may skip assignment with static members and incremental rebalances Sophie Blee-Goldman (Jira)
• [jira] [Created] (KAFKA-10078) Partition may skip assignment with static members and incremental rebalances Sophie Blee-Goldman (Jira)
• [jira] [Resolved] (KAFKA-10011) lockedTaskDirectories should be cleared when task gets closed dirty in HandleLostAll Boyang Chen (Jira)
• [jira] [Resolved] (KAFKA-10010) Should make state store registration idempotent Boyang Chen (Jira)
• [jira] [Created] (KAFKA-10077) Filter downstream of state-store results in suprious tombstones Andy Coates (Jira)
• [jira] [Resolved] (KAFKA-9392) Document and add test for deleteAcls that match single/multiple resources Rajini Sivaram (Jira)
• [jira] [Created] (KAFKA-10076) Doc prefixed vs. non-prefix configs Ron Dagostino (Jira)
• [jira] [Resolved] (KAFKA-10074) Improve performance of `matchingAcls` Ismael Juma (Jira)
• [jira] [Created] (KAFKA-10075) Kafka client stucks after Kafka-cluster unavailability Dmitry Mischenko (Jira)
• Build failed in Jenkins: kafka-trunk-jdk11 #1519 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk11 #1520 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk11 #1521 Apache Jenkins Server
• [DISCUSS] KIP-619 Deprecate ConsumerConfig#addDeserializerToConfig(Properties, Deserializer, Deserializer) and ProducerConfig#addSerializerToConfig(Properties, Serializer, Serializer) Chia-Ping Tsai
  • Re: [DISCUSS] KIP-619 Deprecate ConsumerConfig#addDeserializerToConfig(Properties, Deserializer, Deserializer) and ProducerConfig#addSerializerToConfig(Properties, Serializer, Serializer) Cheng Tan
• [jira] [Created] (KAFKA-10074) Improve performance of `matchingAcls` Ismael Juma (Jira)
• [jira] [Created] (KAFKA-10073) EndTxn wait until markers compelete HaiyuanZhao (Jira)
• Request for removal of archive msg104541.html from kafka.apache.org Satya Kotni
  • Re: Request for removal of archive msg104541.html from kafka.apache.org Satya Kotni
• Build failed in Jenkins: kafka-trunk-jdk14 #147 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk14 #148 Apache Jenkins Server
• Re: [DISCUSS] KIP-513: Distinguish between Key and Value serdes in scala wrapper library for kafka streams John Roesler
  • Re: [DISCUSS] KIP-513: Distinguish between Key and Value serdes in scala wrapper library for kafka streams Yuriy Badalyantc
• Build failed in Jenkins: kafka-2.1-jdk8 #266 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.1-jdk8 #267 Apache Jenkins Server
• Build failed in Jenkins: kafka-2.6-jdk8 #6 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-2.6-jdk8 #7 Apache Jenkins Server
• [jira] [Created] (KAFKA-10072) Kafkaconsumer is configured with different clientid parameters to obtain different results victor (Jira)
• [jira] [Created] (KAFKA-10071) TopicCommand tool should make more efficient metadata calls to Kafka Servers Vinoth Chandar (Jira)
• Build failed in Jenkins: kafka-2.5-jdk8 #138 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.5-jdk8 #139 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.5-jdk8 #140 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.5-jdk8 #141 Apache Jenkins Server
• Build failed in Jenkins: kafka-2.3-jdk8 #208 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.3-jdk8 #209 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-2.3-jdk8 #210 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-9494) Include data type of the config in ConfigEntry Rajini Sivaram (Jira)
• Build failed in Jenkins: kafka-trunk-jdk8 #4588 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk8 #4589 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-10061) Flaky Test `ReassignPartitionsIntegrationTest .testCancellation` Jason Gustafson (Jira)
• [jira] [Resolved] (KAFKA-9130) Allow listing consumer groups per state Jason Gustafson (Jira)
• Build failed in Jenkins: kafka-trunk-jdk14 #144 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk14 #145 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk14 #146 Apache Jenkins Server
• Build failed in Jenkins: kafka-trunk-jdk11 #1514 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk11 #1515 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk11 #1516 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk11 #1517 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk11 #1518 Apache Jenkins Server
• [jira] [Created] (KAFKA-10070) Parameterize Connect unit tests to remove code duplication Chris Egerton (Jira)
• Build failed in Jenkins: kafka-2.6-jdk8 #3 Apache Jenkins Server
  • Build failed in Jenkins: kafka-2.6-jdk8 #4 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-2.6-jdk8 #5 Apache Jenkins Server
• [DISCUSS] 2.5.1 Bug Fix Release John Roesler
  • Re: [DISCUSS] 2.5.1 Bug Fix Release Ismael Juma
  • Re: [DISCUSS] 2.5.1 Bug Fix Release Bill Bejeck
  • Re: [DISCUSS] 2.5.1 Bug Fix Release Israel Ekpo
• [jira] [Created] (KAFKA-10069) The user-defined "predicate" and "negate" are not removed from Transformation Chia-Ping Tsai (Jira)
• [VOTE] KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations David Jacot
  • Re: [VOTE] KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations Gwen Shapira
• Kafka _Querys Csk Raju
• [jira] [Created] (KAFKA-10068) Verify HighAvailabilityTaskAssignor performance with large clusters and topologies John Roesler (Jira)
• Build failed in Jenkins: kafka-trunk-jdk14 #142 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk14 #143 Apache Jenkins Server
• Build failed in Jenkins: kafka-trunk-jdk8 #4586 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk8 #4587 Apache Jenkins Server
• [jira] [Created] (KAFKA-10067) Provide API to detect cluster nodes version Yanming Zhou (Jira)
• [jira] [Resolved] (KAFKA-10029) Selector.completedReceives should not be modified when channel is closed Rajini Sivaram (Jira)
• [jira] [Created] (KAFKA-10066) TopologyTestDriver.createOutputTopic isn't taking record headers into account during deserialization Stefaan Dutry (Jira)
• [DISCUSSION] KIP-619: Add internal topic creation support Cheng Tan
• [jira] [Created] (KAFKA-10065) One of the Kafka broker processes in the cluster suddenly hangs and becomes unresponsive akihiro kumabe (Jira)
• [jira] [Created] (KAFKA-10064) Add documentation for KIP-571 Boyang Chen (Jira)
• [VOTE] KIP-418: A method-chaining way to branch KStream Ivan Ponomarev
• [jira] [Created] (KAFKA-10063) UnsupportedOperation when querying cleaner metrics after shutdown Jason Gustafson (Jira)
• Build failed in Jenkins: kafka-2.5-jdk8 #136 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-2.5-jdk8 #137 Apache Jenkins Server
• [jira] [Created] (KAFKA-10062) Add a method to retrieve the current timestamp as known by the Streams app Piotr Smolinski (Jira)
• [jira] [Created] (KAFKA-10061) Flaky Test `ReassignPartitionsIntegrationTest .testCancellation` Jason Gustafson (Jira)
• Build failed in Jenkins: kafka-trunk-jdk14 #138 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk14 #139 Apache Jenkins Server
• New release branch 2.6 Randall Hauch
• [jira] [Created] (KAFKA-10060) Kafka is logging too verbosely at the INFO level Greg Hamilton (Jira)
• Build failed in Jenkins: kafka-trunk-jdk8 #4582 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4583 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk8 #4584 Apache Jenkins Server
• [jira] [Created] (KAFKA-10059) KafkaAdminClient returns null OffsetAndMetadata value when there is no committed offset for a partition Bob Barrett (Jira)
• Re: Streams, Kafka windows John Roesler
• [jira] [Created] (KAFKA-10058) Create Windowing Operations overview documentation John Roesler (Jira)
• [jira] [Resolved] (KAFKA-9673) Conditionally apply SMTs Randall Hauch (Jira)
• [jira] [Resolved] (KAFKA-9971) Error Reporting in Sink Connectors Randall Hauch (Jira)
• Broker side round robin on topic partitions when receiving messages Vinicius Scheidegger
• [jira] [Created] (KAFKA-10057) optimize class ConfigCommand method alterConfig parameters qianrui (Jira)
• Build failed in Jenkins: kafka-trunk-jdk14 #136 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk14 #137 Apache Jenkins Server
• [jira] [Created] (KAFKA-10056) Consumer metadata may use outdated groupSubscription that doesn't contain newly subscribed topics Rajini Sivaram (Jira)
• Build failed in Jenkins: kafka-trunk-jdk11 #1508 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk11 #1509 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk11 #1510 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-10052) Flaky Test InternalTopicsIntegrationTest.testCreateInternalTopicsWithFewerReplicasThanBrokers Konstantine Karantasis (Jira)
• Build failed in Jenkins: kafka-2.5-jdk8 #134 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-2.5-jdk8 #135 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-9802) Fix flaky system test `TransactionsTest.test_transactions` Jason Gustafson (Jira)
• Build failed in Jenkins: kafka-trunk-jdk11 #1506 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk11 #1507 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-9960) Metrics Reporter should support additional context tags Randall Hauch (Jira)
• Build failed in Jenkins: kafka-trunk-jdk14 #134 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk14 #135 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance Sophie Blee-Goldman (Jira)
• [jira] [Created] (KAFKA-10055) Add shared internal utility class Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-9952) Reconsider immediate propagation of hw when replica selector is used Jason Gustafson (Jira)
• [jira] [Reopened] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-658) Implement "Exact Mirroring" functionality in mirror maker Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-617) Refactor KafkaApis.handleListOffsetRequest Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-205) Audit swallowing of exceptions/throwables Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-72) Redo config objects with default arguments Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-40) Time based log rolling Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-39) javaapi does not declare IOException to be thrown Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-10054) Add TRACE-level end-to-end latency metrics to Streams Sophie Blee-Goldman (Jira)
• [jira] [Resolved] (KAFKA-10045) Kafka Connect Connection leak to Kafka Brokers when using dead letter queue Chris Egerton (Jira)
• [jira] [Created] (KAFKA-10053) Add Document for new feature that Allow HTTP Response Headers to be Configured for Kafka Connect Jeff Huang (Jira)
• [jira] [Resolved] (KAFKA-9561) Update task input partitions when topic metadata changes Guozhang Wang (Jira)
• [jira] [Created] (KAFKA-10052) Flaky Test InternalTopicsIntegrationTest.testCreateInternalTopicsWithFewerReplicasThanBrokers Sophie Blee-Goldman (Jira)
• [jira] [Resolved] (KAFKA-9353) Add groupInstanceId to DescribeGroup for better visibility Jason Gustafson (Jira)
• [jira] [Resolved] (KAFKA-10051) kafka_2.11 2.5.0 isn't available on Maven Central Tom Bentley (Jira)
• [jira] [Created] (KAFKA-10051) kafka_2.11 2.5.0 isn't available on Maven Central Stefan Zwanenburg (Jira)
• [jira] [Created] (KAFKA-10050) kafka_log4j_appender.py broken on JDK11 Nikolay Izhikov (Jira)
• [jira] [Created] (KAFKA-10049) KTable-KTable Foreign Amit Chauhan (Jira)
• Build failed in Jenkins: kafka-trunk-jdk8 #4573 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4574 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4575 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4576 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4577 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4578 Apache Jenkins Server
  • Build failed in Jenkins: kafka-trunk-jdk8 #4579 Apache Jenkins Server
  • Jenkins build is back to normal : kafka-trunk-jdk8 #4580 Apache Jenkins Server
• [jira] [Created] (KAFKA-10048) Possible data gap for a consumer after a failover when using MM2 Andre Araujo (Jira)
• [jira] [Resolved] (KAFKA-5295) Allow Kafka Connect source connectors to specify topic-specific settings for new topics Konstantine Karantasis (Jira)
• [GitHub] [kafka-site] showuon opened a new pull request #266: MINOR: Add more info in the "adding to contributor list" section GitBox
  • [GitHub] [kafka-site] mjsax commented on pull request #266: MINOR: Add more info in the "adding to contributor list" section GitBox
  • [GitHub] [kafka-site] showuon commented on pull request #266: MINOR: Add more info in the "adding to contributor list" section GitBox
  • [GitHub] [kafka-site] mjsax merged pull request #266: MINOR: Add more info in the "adding to contributor list" section GitBox
• [jira] [Created] (KAFKA-10047) Unnecessary widening of (int to long) scope in FloatSerializer Guru Tahasildar (Jira)
• [VOTE] KIP-617: Allow Kafka Streams State Stores to be iterated backwards Jorge Quilcate
  • Re: [VOTE] KIP-617: Allow Kafka Streams State Stores to be iterated backwards Sophie Blee-Goldman
  • Re: [VOTE] KIP-617: Allow Kafka Streams State Stores to be iterated backwards John Roesler
• [jira] [Created] (KAFKA-10046) Deprecated PartitionGrouper config is ignored John Roesler (Jira)
• [jira] [Created] (KAFKA-10045) Kafka Connect Connection leak to Kafka Brokers when using dead letter queue rameshkrishnan muthusamy (Jira)
• [jira] [Resolved] (KAFKA-9898) Flaky Test StoreQueryIntegrationTest.shouldQueryAllStalePartitionStores Guozhang Wang (Jira)
• Re: [VOTE] KIP-557: Add emit on change support for Kafka Streams Randall Hauch
  • Re: [VOTE] KIP-557: Add emit on change support for Kafka Streams Randall Hauch
• [jira] [Created] (KAFKA-10044) Deprecate ConsumerConfig#addDeserializerToConfig(Properties, Deserializer, Deserializer) and ProducerConfig#addSerializerToConfig(Properties, Serializer, Serializer) Chia-Ping Tsai (Jira)
• Build failed in Jenkins: kafka-trunk-jdk8 #4570 Apache Jenkins Server

• Earlier messages