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

See Changes: [github] KAFKA-8164: Add support for retrying failed (#8019) [github] KAFKA-9447: Add new customized EOS model example (#8031) -- [...truncated 2.85

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

Hi Rajini Will accommodate your comments. Celement, while SSLContext factories are common, in this particular case, we need SSLEngine object because Kafka is using SSLEngine (as mentioned much before in this email thread, the SSLContext acts as factory for getting SSLEngine, SSLSocketFactory or

Re: [DISCUSS] KIP-552: Add interface to handle unused config

Sorry for late response. The reason that unused configs is in WARN is that if you misspell a config, it means that it will not apply. In some cases (default retention) you want know until too late. We wanted to warn admins about possible misconfigurations. In the context of a company

[jira] [Resolved] (KAFKA-9447) Add examples for EOS standalone and group mode under kafka/examples

[ https://issues.apache.org/jira/browse/KAFKA-9447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9447. Resolution: Fixed > Add examples for EOS standalone and group mode under kafka/examples >

[jira] [Created] (KAFKA-9513) Failed GroupMetadataManager loadGroupAndOffsets will consider groups as loaded

Lucas Bradstreet created KAFKA-9513: --- Summary: Failed GroupMetadataManager loadGroupAndOffsets will consider groups as loaded Key: KAFKA-9513 URL: https://issues.apache.org/jira/browse/KAFKA-9513

Re: [KAFKA-557] Add emit on change support for Kafka Streams

Hi all, Thanks for the thoughtful comments! I need more time to reflect on your thoughts, but just wanted to offer a quick clarification about equals(). I only meant that we can't be sure if a class's equals() implementation returns true for two semantically identical instances. I.e., if a

[jira] [Resolved] (KAFKA-8164) Improve test passing rate by rerunning flaky tests

[ https://issues.apache.org/jira/browse/KAFKA-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-8164. Fix Version/s: 2.6.0 Resolution: Fixed > Improve test passing rate by rerunning flaky tests

Jenkins build is back to normal : kafka-2.5-jdk8 #5

See

[jira] [Created] (KAFKA-9512) Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration

Matthias J. Sax created KAFKA-9512: -- Summary: Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration Key: KAFKA-9512 URL: https://issues.apache.org/jira/browse/KAFKA-9512 Project: Kafka

[jira] [Created] (KAFKA-9511) Return more specific error and message when producer.initTransaction fails due to missing Kafka configs

Steven Zhang created KAFKA-9511: --- Summary: Return more specific error and message when producer.initTransaction fails due to missing Kafka configs Key: KAFKA-9511 URL:

[jira] [Created] (KAFKA-9510) Quotas may resolve to incorrect value if user is empty

Brian Byrne created KAFKA-9510: -- Summary: Quotas may resolve to incorrect value if user is empty Key: KAFKA-9510 URL: https://issues.apache.org/jira/browse/KAFKA-9510 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

Sanjana Kaundinya created KAFKA-9509: Summary: Fix flaky test MirrorConnectorsIntegrationTest.testReplication Key: KAFKA-9509 URL: https://issues.apache.org/jira/browse/KAFKA-9509 Project: Kafka

Re: [KAFKA-557] Add emit on change support for Kafka Streams

Thanks for the comments, Matthias. w.r.t. requirement of an `equals()` implementation, each template type would have an equals() method. We can use the following code to know whether it is provided by JVM or provided by user. boolean customEquals = false; try { Class cls =

[jira] [Created] (KAFKA-9508) Kafka connect handling of database length checks

Rahul Battacharya created KAFKA-9508: Summary: Kafka connect handling of database length checks Key: KAFKA-9508 URL: https://issues.apache.org/jira/browse/KAFKA-9508 Project: Kafka Issue

[jira] [Created] (KAFKA-9507) AdminClient should check for missing committed offsets

Jason Gustafson created KAFKA-9507: -- Summary: AdminClient should check for missing committed offsets Key: KAFKA-9507 URL: https://issues.apache.org/jira/browse/KAFKA-9507 Project: Kafka

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

See Changes: [github] KAFKA-7489: Backport removal of 0.9 compatibility checks from -- [...truncated 2.99 MB...] kafka.controller.PartitionLeaderElectionAlgorithmsTest >

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

See Changes: [github] KAFKA-9261; Client should handle unavailable leader metadata (#7770) [wangguoz] HOTFIX: checkstyle for newly added unit test -- [...truncated 2.83

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

See Changes: [github] KAFKA-9261; Client should handle unavailable leader metadata (#7770) [wangguoz] HOTFIX: checkstyle for newly added unit test -- [...truncated

[jira] [Created] (KAFKA-9506) Fix JmxReporter corner cases and optimize

Colin McCabe created KAFKA-9506: --- Summary: Fix JmxReporter corner cases and optimize Key: KAFKA-9506 URL: https://issues.apache.org/jira/browse/KAFKA-9506 Project: Kafka Issue Type:

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

See Changes: [github] MINOR: Fix typos introduced in KIP-559 (#8042) -- [...truncated 2.12 MB...] org.apache.kafka.streams.internals.WindowStoreFacadeTest >

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

See Changes: [github] MINOR: Fix typos introduced in KIP-559 (#8042) -- [...truncated 2.13 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest >

[jira] [Resolved] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-7509. -- Resolution: Won't Fix > Kafka Connect logs unnecessary warnings about unused configurations >

[jira] [Resolved] (KAFKA-9261) NPE when updating client metadata

[ https://issues.apache.org/jira/browse/KAFKA-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9261. Resolution: Fixed > NPE when updating client metadata > -

[jira] [Resolved] (KAFKA-9427) StateRestoreListener.onRestoreEnd should report actual message count

[ https://issues.apache.org/jira/browse/KAFKA-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9427. -- Resolution: Fixed This has been fixed as part of KAFKA-9113. >

[jira] [Resolved] (KAFKA-9113) Clean up task management

[ https://issues.apache.org/jira/browse/KAFKA-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9113. -- Fix Version/s: 2.6.0 Resolution: Fixed This clean is done in trunk (2.6.0) now. >

[jira] [Resolved] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

[ https://issues.apache.org/jira/browse/KAFKA-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8574. -- Fix Version/s: 2.6.0 Assignee: Guozhang Wang Resolution: Fixed > EOS race

Build failed in Jenkins: kafka-2.2-jdk8-old #205

See Changes: [rhauch] KAFKA-7489: Backport removal of 0.9 compatibility checks from -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment

Re: [DISCUSS] KIP-552: Add interface to handle unused config

Hi Artur, Thanks for the update! This looks good to me. What do you think about also adding a summary message at WARN level, like: > WARN 42 unknown configs were ignored and logged at DEBUG level. That way, we can quit spamming the logs while still preserving the same level of visibility in

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

Many of these points came up before. I had great hope when Maulin suggested the custom factory could return an SSLContext instead of SSLEngine. SSLContext factories are common, whereas I have never seen an SSLEngine factory being used before. He must have hit the same problem I had with the

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

See Changes: [rhauch] KAFKA-7489: Backport removal of 0.9 compatibility checks from -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment

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

One more point: 5) We should also add a method to SslEngineFactory that returns `Set reconfigurableConfigs()` On Wed, Feb 5, 2020 at 1:50 PM Rajini Sivaram wrote: > Hi Maulin, > > Thanks for the updates. A few comments below: > > 1) SslEngineFactory is currently in the internal package >

Re: [DISCUSS] KIP-552: Add interface to handle unused config

Hi, I updated KIP https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=142641934 and submitted PR accordingly to the discussion in this thread https://github.com/apache/kafka/pull/8043 Please have a look, Artur On Mon, Jan 6, 2020 at 1:22 PM Stanislav Kozlovski wrote: > > Hey

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

Hi Maulin, Thanks for the updates. A few comments below: 1) SslEngineFactory is currently in the internal package org.apache.kafka.common.security.ssl. We should move it to the public package org.apache.kafka.common.security.auth. 2) SslEngineFactory should extend Configurable and Closeable. We

Re: [VOTE] KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies

Hi all, I have made a small change to the KIP during the implementation. We have made the `ProtocolName` field in the `JoinGroupResponse` nullable starting from version 7. We have made this change in order to make the API more consistent. In the `JoinGroupResponse`, `SyncGroupRequest`, and

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

See Changes: [github] MINOR: Fixing null handilg in ValueAndTimestampSerializer (#7679) -- [...truncated 2.11 MB...] org.apache.kafka.streams.MockTimeTest >