Build failed in Jenkins: kafka-2.3-jdk8 #2

See Changes: [jason] MINOR: Work around OpenJDK 11 javadocs issue. (#6747) -- [...truncated 2.89 MB...] kafka.zk.KafkaZkClientTest > testLogDirGetters PASSED kafka.zk.KafkaZk

Build failed in Jenkins: kafka-trunk-jdk11 #554

See Changes: [jason] MINOR: Work around OpenJDK 11 javadocs issue. (#6747) -- [...truncated 2.46 MB...] org.apache.kafka.connect.runtime.distributed.DistributedHerderTest

Build failed in Jenkins: kafka-trunk-jdk8 #3661

See Changes: [jason] MINOR: Work around OpenJDK 11 javadocs issue. (#6747) -- [...truncated 2.46 MB...] org.apache.kafka.connect.header.ConnectHeadersTest > shouldAddDate

[DISCUSS] KIP-472: Add header to RecordContext

Hello, I wish to introduce a minor addition present in RecordContext (a public facing API). This addition works to both provide the user with more information regarding the processing state of the partition, but also help resolve a bug which Kafka is currently experiencing. Here is the KIP Link: h

[jira] [Created] (KAFKA-8400) Do not update follower replica state if the log read failed

Jason Gustafson created KAFKA-8400: -- Summary: Do not update follower replica state if the log read failed Key: KAFKA-8400 URL: https://issues.apache.org/jira/browse/KAFKA-8400 Project: Kafka

Build failed in Jenkins: kafka-2.3-jdk8 #1

See -- [...truncated 2.60 MB...] kafka.zk.KafkaZkClientTest > testUpdateLeaderAndIsr STARTED kafka.zk.KafkaZkClientTest > testUpdateLeaderAndIsr PASSED kafka.zk.KafkaZkClientTest > testUpdat

Build failed in Jenkins: kafka-trunk-jdk11 #553

See Changes: [rhauch] KAFKA-8265: Fix config name to match KIP-458. (#6755) [github] MINOR: Bump version to 2.4.0-SNAPSHOT (#6774) -- [...truncated 2.50 MB...] org.apache

Build failed in Jenkins: kafka-trunk-jdk8 #3660

See Changes: [rhauch] KAFKA-8265: Fix config name to match KIP-458. (#6755) [github] MINOR: Bump version to 2.4.0-SNAPSHOT (#6774) -- [...truncated 2.45 MB...] org.apache

[jira] [Created] (KAFKA-8399) Add back `internal.leave.group.on.close` config for KStreams

Boyang Chen created KAFKA-8399: -- Summary: Add back `internal.leave.group.on.close` config for KStreams Key: KAFKA-8399 URL: https://issues.apache.org/jira/browse/KAFKA-8399 Project: Kafka Issue

[jira] [Created] (KAFKA-8398) NPE when unmapping files after moving log directories using AlterReplicaLogDirs

Vikas Singh created KAFKA-8398: -- Summary: NPE when unmapping files after moving log directories using AlterReplicaLogDirs Key: KAFKA-8398 URL: https://issues.apache.org/jira/browse/KAFKA-8398 Project: Ka

[DISCUSS] KIP-469: Pre-registration support for static members

Hey friends, I would like to start a discussion thread for a low-hanging fruit KIP following up KIP-345 here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-4

[jira] [Created] (KAFKA-8397) Add pre-registration feature for static membership

Boyang Chen created KAFKA-8397: -- Summary: Add pre-registration feature for static membership Key: KAFKA-8397 URL: https://issues.apache.org/jira/browse/KAFKA-8397 Project: Kafka Issue Type: Impr

New release branch 2.3

Hi all, At this point, 2.3 has hit feature freeze. At this point, we expect bugfixes and stabilization efforts to go into 2.3, but not new features. Several things slipped from this release. Just off the top of my head, this list includes KIP-359: Verify epoch in produce requests, KIP-382: M

Build failed in Jenkins: kafka-trunk-jdk8 #3659

See Changes: [jason] KAFKA-8316; Remove deprecated usage of Slf4jRequestLog, -- [...truncated 2.45 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIf

Build failed in Jenkins: kafka-trunk-jdk11 #552

See Changes: [jason] KAFKA-8316; Remove deprecated usage of Slf4jRequestLog, -- [...truncated 2.45 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest > should

[VOTE] KIP-466: Add support for List serialization and deserialization

Hello, I want to start a vote for KIP-466 "Add support for List serialization and deserialization”. The implementation can be found as a PR

[jira] [Resolved] (KAFKA-5476) Implement a system test that creates network partitions

[ https://issues.apache.org/jira/browse/KAFKA-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-5476. Resolution: Duplicate > Implement a system test that creates network partitions > -

Contributor

Hi, I want to contribute to Apache Kafka. Would you please give me the contributor permission? My JIRA ID is shark.chen.

v2 ProduceResponse documentation wrong?

Hi, on parsing the a v2 ProduceResponse from Kafka I am seeing a discrepancy from the documentation. Specifically the base_offset and log_append_time fields appear to be in the opposite positions to those documented in the protocol guide: https://kafka.apache.org/protocol#The_Messages_Produce

Build failed in Jenkins: kafka-trunk-jdk8 #3658

See Changes: [jason] MINOR: Add log when the consumer does not send an offset commit due to [github] KAFKA-8381; Disable hostname validation when verifying inter-broker SSL -

Re: Contributor

Hi, Thanks for your interest in contributing to Apache Kafka. You should be all set now. Thanks, Bill On Mon, May 20, 2019 at 2:31 PM wrote: > Hi, > > > > I want to contribute to Apache Kafka. > > Would you please give me the contributor permission? > > My JIRA ID is shark.chen. > > > >

Build failed in Jenkins: kafka-trunk-jdk11 #551

See Changes: [jason] MINOR: Add log when the consumer does not send an offset commit due to [github] KAFKA-8381; Disable hostname validation when verifying inter-broker SSL -

Contributor

Hi, I want to contribute to Apache Kafka. Would you please give me the contributor permission? My JIRA ID is shark.chen.

[jira] [Resolved] (KAFKA-7921) Instable KafkaStreamsTest

[ https://issues.apache.org/jira/browse/KAFKA-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7921. Resolution: Fixed Let's re-open this if we see another failure. > Instable KafkaStreamsTes

Build failed in Jenkins: kafka-2.1-jdk8 #197

See Changes: [bill] KAFKA-8290: Close producer for zombie task (#6636) -- [...truncated 972.89 KB...] kafka.coordinator.group.GroupCoordinatorTest > testFetchOffsetNotCoordi

Re: [DISCUSS] KIP-471: Expose RocksDB Metrics in Kafka Streams

Hi Bruno, Looks really good overall. This is going to be an awesome addition. My only thought was that we have "bytes-flushed-(rate|total) and flush-time-(avg|min|max)" metrics, and the description states that these are specifically for Memtable flush operations. What do you think about calling i

[jira] [Resolved] (KAFKA-7992) Add a server start time metric

[ https://issues.apache.org/jira/browse/KAFKA-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7992. Resolution: Fixed Fix Version/s: 2.3.0 > Add a server start time metric > --

[jira] [Resolved] (KAFKA-8316) Remove deprecated usage of Slf4jRequestLog, SslContextFactory

[ https://issues.apache.org/jira/browse/KAFKA-8316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8316. Resolution: Fixed > Remove deprecated usage of Slf4jRequestLog, SslContextFactory > ---

[jira] [Resolved] (KAFKA-7358) Alternative Partitioner to Support "Always Round-Robin" Selection

[ https://issues.apache.org/jira/browse/KAFKA-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7358. Resolution: Duplicate > Alternative Partitioner to Support "Always Round-Robin" Selection >

Build failed in Jenkins: kafka-trunk-jdk8 #3657

See Changes: [github] KAFKA-8290: Close producer for zombie task (#6636) -- [...truncated 2.54 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldNot

Re: [DISCUSS] KIP-471: Expose RocksDB Metrics in Kafka Streams

Hi Bruno, Thanks for the KIP, this will be a useful addition. Overall the KIP looks good to me, and I have two minor comments. 1. For the tags should, I'm wondering if rocksdb-state-id should be rocksdb-store-id instead? 2. With the compaction metrics, would it be possible to add total compacti

[jira] [Resolved] (KAFKA-8381) SSL factory for inter-broker listener is broken

[ https://issues.apache.org/jira/browse/KAFKA-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8381. --- Resolution: Fixed Reviewer: Manikumar > SSL factory for inter-broker listener is broken

[jira] [Created] (KAFKA-8396) Clean up Transformer API

John Roesler created KAFKA-8396: --- Summary: Clean up Transformer API Key: KAFKA-8396 URL: https://issues.apache.org/jira/browse/KAFKA-8396 Project: Kafka Issue Type: Improvement Compon

Build failed in Jenkins: kafka-trunk-jdk11 #550

See Changes: [github] KAFKA-8290: Close producer for zombie task (#6636) -- [...truncated 2.46 MB...] org.apache.kafka.streams.scala.kstream.JoinedTest > Create a Joined s

[jira] [Resolved] (KAFKA-8376) Flaky test ClientAuthenticationFailureTest.testTransactionalProducerWithInvalidCredentials test.

[ https://issues.apache.org/jira/browse/KAFKA-8376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8376. Resolution: Fixed > Flaky test > ClientAuthenticationFailureTest.testTransactionalProducer

[jira] [Created] (KAFKA-8395) Add an ability to backup log segment files on truncation

Michael Axiak created KAFKA-8395: Summary: Add an ability to backup log segment files on truncation Key: KAFKA-8395 URL: https://issues.apache.org/jira/browse/KAFKA-8395 Project: Kafka Issue

Re: [VOTE] KIP-369 Alternative Partitioner to Support "Always Round-Robin" Selection

I have now submitted the PR for review. Thanks Matthias for pointing out that KAFKA- was raised to address the same. https://github.com/apache/kafka/pull/6771 if someone reviews after Jenkins build is complete, I would appreciate it. Thanks, On Fri, 17 May 2019 at 22:18, M. Manna wrote: >

Re: [DISCUSS] KIP-471: Expose RocksDB Metrics in Kafka Streams

Hi Sophie, Thank you for your comments. It's a good idea to supplement the metrics with configuration option to change the metrics. I also had some thoughts about it. However, I think I need some experimentation to get this right. I added the block cache hit rates for index and filter blocks to

Re: [DISCUSS] KIP-456: Helper classes to make it simpler to write test logic with TopologyTestDriver

Hi All, Inspired by the discussion in this thread, there is a new KIP-470: TopologyTestDriver test input and output usability improvements: https://cwiki.apache.org/confluence/display/KAFKA/KIP-470%3A+TopologyTestDriver+test+input+and+output+usability+improvements This KIP can be discarded if KI

[DISCUSS] KIP-470: TopologyTestDriver test input and output usability improvements

Hi All, I would like to start the discussion on KIP-470: TopologyTestDriver test input and output usability improvements: https://cwiki.apache.org/confluence/display/KAFKA/KIP-470%3A+TopologyTestDriver+test+input+and+output+usability+improvements This KIP is inspired by the Discussion in KIP-456

[jira] [Created] (KAFKA-8394) Cannot Start a build with New Gradle Version

M. Manna created KAFKA-8394: --- Summary: Cannot Start a build with New Gradle Version Key: KAFKA-8394 URL: https://issues.apache.org/jira/browse/KAFKA-8394 Project: Kafka Issue Type: Bug Co

Re: [kafka-clients] Re: [VOTE] 2.2.1 RC1

Hello, I have run the tests, all tests passed. I have also run the quick start and test my apps with that commit 55783d313, everything worked. +1 Thanks a lot for the release, I have been waiting for a bug fix on this release for long, yuju! :) Cheers! -- Jonathan On Sat, May 18, 2019 at 2:17

[jira] [Created] (KAFKA-8393) Kafka Connect: Kafka Connect: could not get type for name org.osgi.framework.BundleListener on Windows

Loïc created KAFKA-8393: --- Summary: Kafka Connect: Kafka Connect: could not get type for name org.osgi.framework.BundleListener on Windows Key: KAFKA-8393 URL: https://issues.apache.org/jira/browse/KAFKA-8393 Pr