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

See Changes: [rhauch] KAFKA-8974: Trim whitespaces in topic names in sink connector configs [wangguoz] MINOR: just remove leader on trunk like we did on 2.3 (#7447) [wangguoz] KAFKA-8934: Introduce

Jenkins build is back to normal : kafka-2.2-jdk8 #175

See

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

See Changes: [wangguoz] KAFKA-8649: send latest commonly supported version in assignment (#7427) -- Started by an SCM change Started by an SCM change Started by an SCM

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

See Changes: [rhauch] KAFKA-8974: Trim whitespaces in topic names in sink connector configs -- [...truncated 230.87 KB...] kafka.api.GroupAuthorizerIntegrationTest >

Re: [kafka-clients] Re: [VOTE] 2.3.1 RC0

RC0 was cancelled and a new voting thread for RC1 was just sent out. Thanks! On Fri, Oct 4, 2019 at 11:06 AM Matt Farmer wrote: > Do we have an ETA on when y'all think 2.3.1 will land? > > On Sat, Sep 28, 2019 at 1:55 PM Matthias J. Sax > wrote: > > > There was a recent report about

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

See Changes: [rhauch] KAFKA-8974: Trim whitespaces in topic names in sink connector configs [matthias] KAFKA-8649: send latest commonly supported version in assignment (#7425)

[VOTE] 2.3.1 RC1

Hello all, we identified a few bugs and a dependency update we wanted to get fixed for 2.3.1. In particular, there was a problem with rolling upgrades of streams applications (KAFKA-8649). Check out the release notes for a complete list.

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

See Changes: [cmccabe] Part 1 of KIP-511: Collect and Expose Client's Name and Version in the -- [...truncated 1.72 MB...] kafka.api.PlaintextConsumerTest >

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

See Changes: [rhauch] KAFKA-8974: Trim whitespaces in topic names in sink connector configs -- [...truncated 2.65 MB...] org.apache.kafka.streams.TopologyTestDriverTest

[jira] [Created] (KAFKA-8989) Embedded broker could not be reached in unit test

Boyang Chen created KAFKA-8989: -- Summary: Embedded broker could not be reached in unit test Key: KAFKA-8989 URL: https://issues.apache.org/jira/browse/KAFKA-8989 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-8988) Replace CreatePartitions request/response with automated protocol

Vikas Singh created KAFKA-8988: -- Summary: Replace CreatePartitions request/response with automated protocol Key: KAFKA-8988 URL: https://issues.apache.org/jira/browse/KAFKA-8988 Project: Kafka

[jira] [Resolved] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0

[ https://issues.apache.org/jira/browse/KAFKA-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8649. Fix Version/s: 2.3.1 2.4.0 Resolution: Fixed > Error

[jira] [Created] (KAFKA-8987) Allow IQ on restored state stores while others are still restoring

Sophie Blee-Goldman created KAFKA-8987: -- Summary: Allow IQ on restored state stores while others are still restoring Key: KAFKA-8987 URL: https://issues.apache.org/jira/browse/KAFKA-8987

[jira] [Created] (KAFKA-8986) Allow null as a valid default for tagged fields

Colin McCabe created KAFKA-8986: --- Summary: Allow null as a valid default for tagged fields Key: KAFKA-8986 URL: https://issues.apache.org/jira/browse/KAFKA-8986 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8985) Use flexibleVersions with LeaderAndIsr, and improve RequestResponseTest coverage

Colin McCabe created KAFKA-8985: --- Summary: Use flexibleVersions with LeaderAndIsr, and improve RequestResponseTest coverage Key: KAFKA-8985 URL: https://issues.apache.org/jira/browse/KAFKA-8985

[jira] [Created] (KAFKA-8984) Improve tagged fields documentation

Colin McCabe created KAFKA-8984: --- Summary: Improve tagged fields documentation Key: KAFKA-8984 URL: https://issues.apache.org/jira/browse/KAFKA-8984 Project: Kafka Issue Type: Improvement

Re: [DISCUSS] KIP-519: Make SSL context/engine configuration extensible

In other words, Kafka doesn't necessarily need to derive another interface/mechanism to make SSLEngine pluggable. That interface/mechanism exists in Java with Security Provider's SSLContext Algorithms. Ref-1:

Build failed in Jenkins: kafka-2.2-jdk8 #174

See Changes: [rhauch] KAFKA-8974: Trim whitespaces in topic names in sink connector configs -- Started by an SCM change Started by an SCM change Running as SYSTEM

Build failed in Jenkins: kafka-2.0-jdk8 #296

See Changes: [rhauch] KAFKA-8974: Trim whitespaces in topic names in sink connector configs -- Started by an SCM change Started by an SCM change Running as SYSTEM

[jira] [Created] (KAFKA-8983) AdminClient deleteRecords should not fail all partitions unnecessarily

Jason Gustafson created KAFKA-8983: -- Summary: AdminClient deleteRecords should not fail all partitions unnecessarily Key: KAFKA-8983 URL: https://issues.apache.org/jira/browse/KAFKA-8983 Project:

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

See Changes: [cmccabe] Part 1 of KIP-511: Collect and Expose Client's Name and Version in the -- [...truncated 2.65 MB...]

[jira] [Resolved] (KAFKA-8896) NoSuchElementException after coordinator move

[ https://issues.apache.org/jira/browse/KAFKA-8896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-8896. - Resolution: Fixed > NoSuchElementException after coordinator move >

[jira] [Resolved] (KAFKA-8974) Sink Connectors can't handle topic list with whitespaces

[ https://issues.apache.org/jira/browse/KAFKA-8974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8974. -- Fix Version/s: 2.3.1 2.4.0 2.2.2 2.1.2

[jira] [Created] (KAFKA-8982) Admin.deleteRecords should retry when failing to fetch metadata

Mickael Maison created KAFKA-8982: - Summary: Admin.deleteRecords should retry when failing to fetch metadata Key: KAFKA-8982 URL: https://issues.apache.org/jira/browse/KAFKA-8982 Project: Kafka

[jira] [Created] (KAFKA-8981) Add bandwidth limits to DegradedNetworkFault

David Arthur created KAFKA-8981: --- Summary: Add bandwidth limits to DegradedNetworkFault Key: KAFKA-8981 URL: https://issues.apache.org/jira/browse/KAFKA-8981 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-519: Make SSL context/engine configuration extensible

Hi Clement The explanation about using Java Security Providers if you want to use customize SSLEngine is - similar to BouncyCastleJsseProvider we can have a provider that registers SSLContext+(TLS/SSL) services and have implementation for SSLContextSpi which provides various methods to

Re: [DISCUSS] KIP-526: Reduce Producer Metadata Lookups for Large Number of Topics

Lucas, Guozhang, Thank you for the comments. Good point on METADATA_MAX_AGE_CONFIG - it looks like the ProducerMetadata was differentiating between expiry and refresh, but it should be unnecessary to do so once the cost of fetching a single topic's metadata is reduced. I've updated the rejected

Re: [DISCUSS] KIP-526: Reduce Producer Metadata Lookups for Large Number of Topics

Hello Brian, Thanks for the KIP. I think using asynchronous metadata update to address 1) metadata update blocking send, but for other issues, currently at producer we do have a configurable `METADATA_MAX_AGE_CONFIG` similar to consumer, by default is 5min. So maybe we do not need to introduce

[jira] [Created] (KAFKA-8980) Refactor State-Store-level Metrics

Bruno Cadonna created KAFKA-8980: Summary: Refactor State-Store-level Metrics Key: KAFKA-8980 URL: https://issues.apache.org/jira/browse/KAFKA-8980 Project: Kafka Issue Type: Improvement

RE: [DISCUSS] KIP-519: Make SSL context/engine configuration extensible

I am happy to see I am not the only one with reservations on the direction we were heading. >> I feel if you want to plug any JSSE compatible SSLEngine >> (example BouncyCastle, wildfly-OpenSSL etc) then we have to follow path of >> using Java security provider I like the conclusion but I did

ApacheCon Europe 2019 talks which are relevant to Apache Kafka

Dear Apache Kafka committers, In a little over 2 weeks time, ApacheCon Europe is taking place in Berlin. Join us from October 22 to 24 for an exciting program and lovely get-together of the Apache Community. We are also planning a hackathon.  If your project is interested in participating,

Jenkins build is back to normal : kafka-2.3-jdk8 #119

See

Re: [kafka-clients] Re: [VOTE] 2.3.1 RC0

Do we have an ETA on when y'all think 2.3.1 will land? On Sat, Sep 28, 2019 at 1:55 PM Matthias J. Sax wrote: > There was a recent report about vulnerabilities of some dependent > libraries: https://issues.apache.org/jira/browse/KAFKA-8952 > > I think we should fix this for 2.3.1. > >

Re: [VOTE] KIP-416: Notify SourceTask of ACK'd offsets, metadata

+1 (binding). Thanks, Harsha On Fri, Oct 04, 2019 at 6:53 AM, Manikumar wrote: > Hi All, > > Please vote here for the formal approval of this KIP. > https://github.com/apache/kafka/pull/6295#discussion_r328867657 > > Thanks, > > > On Wed, Oct 2, 2019 at 5:50 AM Ryanne Dolan wrote: > > Hey

Re: [VOTE] KIP-416: Notify SourceTask of ACK'd offsets, metadata

Hi All, Please vote here for the formal approval of this KIP. https://github.com/apache/kafka/pull/6295#discussion_r328867657 Thanks, On Wed, Oct 2, 2019 at 5:50 AM Ryanne Dolan wrote: > Hey y'all, resurrecting an old KIP for the benefit of KIP-382, which > depends on an additional parameter

[jira] [Created] (KAFKA-8979) Fetch response is frequently split into multiple TCP/IP packets

Piotr Smolinski created KAFKA-8979: -- Summary: Fetch response is frequently split into multiple TCP/IP packets Key: KAFKA-8979 URL: https://issues.apache.org/jira/browse/KAFKA-8979 Project: Kafka

[jira] [Created] (KAFKA-8978) When TLS is applied, broker sends the response frame length in separate TLS packet

Piotr Smolinski created KAFKA-8978: -- Summary: When TLS is applied, broker sends the response frame length in separate TLS packet Key: KAFKA-8978 URL: https://issues.apache.org/jira/browse/KAFKA-8978

[jira] [Created] (KAFKA-8977) Remove MockStreamsMetrics Since it is not a Mock

Bruno Cadonna created KAFKA-8977: Summary: Remove MockStreamsMetrics Since it is not a Mock Key: KAFKA-8977 URL: https://issues.apache.org/jira/browse/KAFKA-8977 Project: Kafka Issue Type:

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

See Changes: [rhauch] KAFKA-8523 Enabling InsertField transform to be used with tombstone [rhauch] KAFKA-6290: Support casting from logical types in cast transform (#7371) [bbejeck] KAFKA-3705 Added a

Re: [DISCUSS] KIP-519: Make SSL context/engine configuration extensible

Hi all I've been having more thoughts on SSLEngine vs SSLContext pluggability (reasons for hiatus from my side until now). Based on my further research and understanding, various TLS implementations https://en.wikipedia.org/wiki/Comparison_of_TLS_implementations , makes it clear that there are