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

See Changes: [github] KAFKA-10002; Improve performances of StopReplicaRequest with large -- [...truncated 3.20 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

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

See Changes: [github] KAFKA-10240: Suppress WakeupExceptions during sink task shutdown (#9003) [github] KAFKA-10192: Wait for REST API to become available before testing

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

See Changes: [github] KAFKA-10240: Suppress WakeupExceptions during sink task shutdown (#9003) [github] KAFKA-10192: Wait for REST API to become available before testing

Build failed in Jenkins: kafka-2.6-jdk8 #81

See Changes: [konstantine] KAFKA-10192: Wait for REST API to become available before testing -- [...truncated 6.31 MB...]

Build failed in Jenkins: kafka-trunk-jdk14 #290

See Changes: [github] KAFKA-10240: Suppress WakeupExceptions during sink task shutdown (#9003) [github] KAFKA-10192: Wait for REST API to become available before testing

Re: [DISCUSS] KIP-578: Add configuration to limit number of partitions

Ismael, I have updated the KIP to reuse the PolicyViolationException. It is not clear to me there is a value in either having a new exception type or in renaming the existing exception. For error codes, we'll just use POLICY_VIOLATION. This should work well for existing clients also since they

[jira] [Created] (KAFKA-10271) Performance degradation while fetching a key from a single partition

Dima R created KAFKA-10271: -- Summary: Performance degradation while fetching a key from a single partition Key: KAFKA-10271 URL: https://issues.apache.org/jira/browse/KAFKA-10271 Project: Kafka

Re: [VOTE] KIP-554: Add Broker-side SCRAM Config API

Hi again, Colin. I also just realized a couple of other incompatibilities with the way kafka-configs works today that prevents --bootstrap-server from being a drop-in replacement. This may or may not be a hard requirement, but we should explicitly decide on these one way or the other. One issue

Re: [DISCUSS] KIP-450: Sliding Windows

Hi Leah, Thank you for the KIP! Here is my feedback: 1. The KIP would benefit from some code examples that show how to use sliding windows in aggregations. 2. The different sliding windows in Figure 1 and 2 are really hard to distinguish. Could you please try to make them graphically better

Re: [DISCUSS] KIP-450: Sliding Windows

Hello Leah, Thanks for the nice written KIP. A few thoughts: 1) I echo the other reviewer's comments regarding the typing: why extending TimeWindow instead of just extending Window? 2) I also feel that emitting policy for this type of windowing aggregation may be different from the existing

[jira] [Resolved] (KAFKA-10229) Kafka stream dies for no apparent reason, no errors logged on client or server

[ https://issues.apache.org/jira/browse/KAFKA-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta resolved KAFKA-10229. - Resolution: Invalid Not an issue with Kafka -- the code run by the stream was blocked. > Kafka

Re: [VOTE] KIP-554: Add Broker-side SCRAM Config API

On Tue, Jul 14, 2020, at 07:57, Ron Dagostino wrote: > Hi again, Colin. I also just realized a couple of other incompatibilities > with the way kafka-configs works today that prevents --bootstrap-server > from being a drop-in replacement. This may or may not be a hard > requirement, but we

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi Jun, Hi Colin, Satish and I are still discussing some details about how to handle transactions / producer ids. Satish is going to make some minor changes to RLMM API and other parts. Other than that, we have finished updating the KIP I agree with Colin that the current design of using rocksDB

Re: [DISCUSS] Apache Kafka 2.6.0 release

I've just announced 2.6.0 RC0 in a vote thread to this list. If you find any issues, please reply to that "[VOTE] 2.6.0 RC0" thread. Thanks, and best regards! Randall On Fri, Jul 10, 2020 at 7:44 PM Matthias J. Sax wrote: > Randall, > > we found another blocker: >

[jira] [Created] (KAFKA-10272) kafka-server-stop.sh fails on IBM i

Jesse Gorzinski created KAFKA-10272: --- Summary: kafka-server-stop.sh fails on IBM i Key: KAFKA-10272 URL: https://issues.apache.org/jira/browse/KAFKA-10272 Project: Kafka Issue Type: Bug

Jenkins build is back to normal : kafka-trunk-jdk8 #4716

See

[jira] [Resolved] (KAFKA-10274) Transaction system test uses inconsistent timeouts

[ https://issues.apache.org/jira/browse/KAFKA-10274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10274. - Resolution: Fixed Looks like this issue was already fixed by KAFKA-10235 and I had an

Build failed in Jenkins: kafka-trunk-jdk14 #291

See Changes: [github] MINOR: Remove call to Exit.exit() to prevent infinite recursion in -- [...truncated 6.40 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Jenkins build is back to normal : kafka-2.6-jdk8 #82

See

Re: [DISCUSS] 2.5.1 Bug Fix Release

Hello again, all, Just in case you were waiting for the RC, I wanted to give a quick update. I got hung up in the first-time setup for cutting a release and wasn't able to finish it last Friday. I'm getting ready to record a talk for Kafka Summit tomorrow, after which I'll be able to pick up the

Jenkins build is back to normal : kafka-trunk-jdk11 #1643

See

[jira] [Reopened] (KAFKA-10274) Transaction system test uses inconsistent timeouts

[ https://issues.apache.org/jira/browse/KAFKA-10274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-10274: - Apologies for the noise, but I'm going to reopen this. The recent fix addressed the issue

[VOTE] 2.6.0 RC0

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 2.6.0. This is a major release that includes many new features, including: * TLSv1.3 has been enabled by default for Java 11 or newer. * Smooth scaling out of Kafka Streams applications *

Re: [VOTE] 2.6.0 RC0

Docs link [1] is broken. [1] https://kafka.apache.org/26/documentation.html From: Randall Hauch Sent: Tuesday, July 14, 2020 4:57 PM To: dev ; Users ; kafka-clients Subject: [VOTE] 2.6.0 RC0 Hello Kafka users, developers and client-developers, This is the

Re: [VOTE] 2.6.0 RC0

Thanks for catching that, Gary. Apologies to all for announcing this before pushing the docs, but that's fixed and the following links are working (along with the others in my email): * https://kafka.apache.org/26/documentation.html * https://kafka.apache.org/26/protocol.html Randall On Tue,

[jira] [Created] (KAFKA-10273) Connect Converters should produce actionable error messages

Greg Harris created KAFKA-10273: --- Summary: Connect Converters should produce actionable error messages Key: KAFKA-10273 URL: https://issues.apache.org/jira/browse/KAFKA-10273 Project: Kafka

Re: [VOTE] KIP-554: Add Broker-side SCRAM Config API

Thanks, Colin. DescribeScramUsersResponse returns a list of ScramUser instances, which makes sense, but then each of the ScramUser instances only has a single ScramUserMechanismInfo instance. I believe it needs a List of those? Also, ScramUserMechanismInfo probably needs a better "about" value

[jira] [Created] (KAFKA-10274) Transaction system test uses inconsistent timeouts

Jason Gustafson created KAFKA-10274: --- Summary: Transaction system test uses inconsistent timeouts Key: KAFKA-10274 URL: https://issues.apache.org/jira/browse/KAFKA-10274 Project: Kafka

Re: [DISCUSS] KIP-595: A Raft Protocol for the Metadata Quorum

Hi Jason, Ghouzang and Boyang, First, thanks for the KIP. I've not a few minor suggestions and nits, but on the whole it was pretty clear and understandable. 1. § Motivation "We have intentionally avoided any assumption about the representation of the log and its semantics." I found this a