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

See Changes: -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables. Building remotely on H23 (ubuntu) in workspace

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

See Changes: -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables. Building remotely on H23 (ubuntu) in workspace

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

See Changes: -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables. Building remotely on H23 (ubuntu) in workspace

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

See Changes: -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables. Building remotely on H23 (ubuntu) in workspace

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

See Changes: -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables. Building remotely on H23 (ubuntu) in workspace

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

See

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

See

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

See Changes: -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables. Building remotely on H23 (ubuntu) in workspace

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

See Changes: -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables. Building remotely on H23 (ubuntu) in workspace

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

See

Re: [VOTE] KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

+1 (not binding) Thanks for the KIP! -Anna On Thu, Jun 4, 2020 at 8:26 AM Mickael Maison wrote: > +1 (binding) > Thanks David for looking into this important issue > > On Thu, Jun 4, 2020 at 3:59 PM Tom Bentley wrote: > > > > +1 (non binding). > > > > Thanks! > > > > On Wed, Jun 3, 2020 at 3:

Re: KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

Hi David, The KIP looks good to me. I am going to the voting thread... Hi Jun, Yes, exactly. That's a separate thing from this KIP, so working on the fix. Thanks, Anna On Fri, Jun 5, 2020 at 4:36 PM Jun Rao wrote: > Hi, Anna, > > Thanks for the comment. For the problem that you described, pe

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

See Changes: -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables. Building remotely on H23 (ubuntu) in workspace

Re: KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

Hi, Anna, Thanks for the comment. For the problem that you described, perhaps we need to make the quota checking and recording more atomic? Hi, David, Thanks for the updated KIP. Looks good to me now. Just one minor comment below. 30. controller_mutations_rate: For topic creation and deletion,

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

See Changes: [github] KAFKA-10110: Corrected potential NPE when null label value added to [github] KAFKA-10111: Make SinkTaskContext.errantRecordReporter() a default [github] KAFKA-9570: Define SSL configs in

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

See Changes: [github] HOT_FIX: Update javadoc since imports added (#8817) [github] KAFKA-9840; Skip End Offset validation when the leader epoch is not -- Started by an S

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

See Changes: [github] fix the broken links of streams javadoc (#8789) [github] KAFKA-9441: Improve Kafka Streams task management (#8776) [github] MINOR: Fix javadoc warnings (#8809) [manikumar] MINOR: fix back

Re: [VOTE] KIP-601: Configurable socket connection timeout in NetworkClient

The KIP is approved upon 3 binding votes. Thanks for all the feedback and votes! - Cheng

Re: [VOTE] KIP-601: Configurable socket connection timeout in NetworkClient

+1 (binding) Thank you for the contribution. On Wed, Jun 3, 2020 at 12:53 AM Cheng Tan wrote: > Dear Rajini, > > Thanks for the feedback. > > 1) > Because "request.timeout.ms" only affects in-flight requests, after the > API NetworkClient.ready() is invoked, the connection won't get closed afte

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

See Changes: [github] KAFKA-8011: Fix flaky RegexSourceIntegrationTest (#8799) -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variab

[jira] [Resolved] (KAFKA-9570) SSL cannot be configured for Connect in standalone mode

[ https://issues.apache.org/jira/browse/KAFKA-9570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9570. -- Fix Version/s: 2.5.1 2.4.2 2.6.0 Reviewer: Randal

[jira] [Resolved] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8011. Assignee: Matthias J. Sax (was: Sophie Blee-Goldman) Resolution: Fixed The currently

Re: Permission to create KIP

Done. On 6/5/20 12:05 AM, William Bottrell wrote: > Hello, > > I'd like to get permission to create a KIP for this JIRA issue: > https://issues.apache.org/jira/browse/KAFKA-10062. Not sure what my WIki ID > is, but my account name is wbottrell. Let me know if that is incorrect or > if more inform

Re: [VOTE] KIP-620 Deprecate ConsumerConfig#addDeserializerToConfig(Properties, Deserializer, Deserializer) and ProducerConfig#addSerializerToConfig(Properties, Serializer, Serializer)

+1 (binding) Thanks for the KIP! -Matthias On 6/4/20 11:25 PM, Chia-Ping Tsai wrote: > hi All, > > I would like to start the vote on KIP-620: > > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=155749118 > > -- > Chia-Ping > signature.asc Description: OpenPGP digital sig

Jenkins build is back to normal : kafka-trunk-jdk14 #180

See

[jira] [Created] (KAFKA-10112) Consider making the number of threads configurable for offset/group metadata cache loading

Manikumar created KAFKA-10112: - Summary: Consider making the number of threads configurable for offset/group metadata cache loading Key: KAFKA-10112 URL: https://issues.apache.org/jira/browse/KAFKA-10112

Re: [DISCUSS] KIP-158 UPDATED: Enable source connectors to create new topics with specific configs in Kafka Connect during runtime

LGTM. Thanks! On Fri, Jun 5, 2020 at 12:41 PM Konstantine Karantasis < konstant...@confluent.io> wrote: > Thanks for bringing up KIP-464 Jose and apologies for taking that long to > respond. > > It made sense to allow the users to use the broker defaults for the > replication factor and the numbe

Re: [DISCUSS] KIP-158 UPDATED: Enable source connectors to create new topics with specific configs in Kafka Connect during runtime

Thanks for bringing up KIP-464 Jose and apologies for taking that long to respond. It made sense to allow the users to use the broker defaults for the replication factor and the number of partitions when their source connectors create topics and the implementation has incorporated this ability. I'

Re: [VOTE] KIP-610: Error Reporting in Sink Connectors

Thanks again to everyone for all the work on this KIP and implementation! I've discovered that it would be easier for downstream projects if the new `SinkTaskContext.errantRecordReporter()` method were a default method that returns null. Strictly speaking it's not required as Connect will provide

[jira] [Created] (KAFKA-10111) SinkTaskContext.errantRecordReporter() added in KIP-610 should be a default method

Randall Hauch created KAFKA-10111: - Summary: SinkTaskContext.errantRecordReporter() added in KIP-610 should be a default method Key: KAFKA-10111 URL: https://issues.apache.org/jira/browse/KAFKA-10111

[jira] [Created] (KAFKA-10110) ConnectDistributed fails with NPE when Kafka cluster has no ID

Randall Hauch created KAFKA-10110: - Summary: ConnectDistributed fails with NPE when Kafka cluster has no ID Key: KAFKA-10110 URL: https://issues.apache.org/jira/browse/KAFKA-10110 Project: Kafka

Re: KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

Hi Anna and Jun, You are right. We should allocate up to the quota for each old sample. I have revamped the Throttling Algorithm section to better explain our thought process and the token bucket inspiration. I have also added a chapter with few guidelines about how to define the quota. There is

Permission to create KIP

Hello, I'd like to get permission to create a KIP for this JIRA issue: https://issues.apache.org/jira/browse/KAFKA-10062. Not sure what my WIki ID is, but my account name is wbottrell. Let me know if that is incorrect or if more information is needed. Thanks, Will

[jira] [Created] (KAFKA-10109) kafka-acls.sh/AclCommand opens multiple AdminClients

Tom Bentley created KAFKA-10109: --- Summary: kafka-acls.sh/AclCommand opens multiple AdminClients Key: KAFKA-10109 URL: https://issues.apache.org/jira/browse/KAFKA-10109 Project: Kafka Issue Type

Re: Broker side round robin on topic partitions when receiving messages

Does anyone know how could I perform a load balance to distribute equally the messages to all consumers within the same consumer group having multiple producers? Is this a conceptual flaw on Kafka, wasn't it thought for equal distribution with multiple producers or am I missing something? I've ask

[jira] [Created] (KAFKA-10108) The cached configs of SslFactory should be updated only if the ssl Engine Factory is updated successfully

Chia-Ping Tsai created KAFKA-10108: -- Summary: The cached configs of SslFactory should be updated only if the ssl Engine Factory is updated successfully Key: KAFKA-10108 URL: https://issues.apache.org/jira/browse/

[jira] [Created] (KAFKA-10107) Producer snapshots LSO used in certain situations which can lead to data loss on compacted topics as LSO breach occurs and early offsets cleaned

William Reynolds created KAFKA-10107: Summary: Producer snapshots LSO used in certain situations which can lead to data loss on compacted topics as LSO breach occurs and early offsets cleaned Key: KAFKA-10107