Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #304

See Changes: [github] MINOR: Make Histogram#clear more readable (#9679) [github] KAFKA-10803: Fix improper removal of bad dynamic config (#9682) --

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #68

See Changes: [David Arthur] KAFKA-10799 AlterIsr utilizes ReplicaManager ISR metrics (#9677) -- [...truncated 6.87 MB...]

[DISCUSS] KIP-687: Automatic Reloading of Security Store

Hey there, I would like to start the discussion thread for KIP-687: https://cwiki.apache.org/confluence/display/KAFKA/KIP-687%3A+Automatic+Reloading+of+Security+Store This KIP is trying to deprecate the AlterConfigs API support of updating the security store by reloading path in-place, and

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #257

See

[jira] [Created] (KAFKA-10807) AlterConfig should be validated by the target broker

Boyang Chen created KAFKA-10807: --- Summary: AlterConfig should be validated by the target broker Key: KAFKA-10807 URL: https://issues.apache.org/jira/browse/KAFKA-10807 Project: Kafka Issue

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #67

See Changes: [Matthias J. Sax] MINOR: Fix KTable-KTable foreign-key join example (#9683) -- [...truncated 6.87 MB...]

Re: [DISCUSS] KIP-631: The Quorum-based Kafka Controller

Hi, Colin, Thanks for the updated KIP. A few more comments below. 80.2 For deprecated configs, we need to include zookeeper.* and broker.id.generation.enable. 83.1 If a broker is down, does the controller keep the previously registered broker epoch forever? If not, how long does the controller

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #280

See Changes: [github] KAFKA-10473: Add docs on partition size-on-disk, and other log-related metrics (#9276) [github] MINOR: Fix KTable-KTable foreign-key join example (#9683)

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #56

See Changes: [Matthias J. Sax] MINOR: Fix KTable-KTable foreign-key join example (#9683) -- [...truncated 3.16 MB...]

Re: [DISCUSS] KIP-689: Extend `StreamJoined` to allow more store configs

Ahh, that makes sense. Thanks for clarifying! On Thu, Dec 3, 2020 at 3:01 PM Matthias J. Sax wrote: > Thanks for looking into it. I also needed to refresh my memory. > > In Scala, it's sufficient to expose the `static` methods for a native > Scala integration. If you look into the code, those

Re: [VOTE] KIP-661: Expose task configurations in Connect REST API

Hi Mickael, This KIP looks like it will be useful. +1 (binding) Thanks, Bill On Thu, Nov 19, 2020 at 7:04 AM Mickael Maison wrote: > Bumping this thread > > So far we have 1 binding and 3 non binding votes. > Let me know if you have any feedback. > > Thanks > > On Mon, Nov 2, 2020 at 12:16

Re: [DISCUSS] KIP-690 Add additional configuration to control MirrorMaker 2 internal topics naming convention

Hi Mickael, Thanks for your feedback! Regards your question about having more configurations, I considered adding configuration per each topic however this meant adding more configurations for MM2 which already have so many, also the more complicated and advanced replication pattern you have

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #302

See

[jira] [Created] (KAFKA-10806) throwable from user callback on completeFutureAndFireCallbacks can lead to unhandled exceptions

xiongqi wu created KAFKA-10806: -- Summary: throwable from user callback on completeFutureAndFireCallbacks can lead to unhandled exceptions Key: KAFKA-10806 URL: https://issues.apache.org/jira/browse/KAFKA-10806

Re: [VOTE] KIP-689: Extend `StreamJoined` to allow more store configs

+1 (binding) On 12/3/20 11:21 AM, Guozhang Wang wrote: > +1 (binding) > > Thanks Leah! > > On Wed, Dec 2, 2020 at 11:27 AM Sophie Blee-Goldman > wrote: > >> Thanks for the KIP! +1 (binding) >> >> Sophie >> >> On Wed, Dec 2, 2020 at 8:42 AM Walker Carlson >> wrote: >> >>> +1 (non-binding) >>>

Re: [DISCUSS] KIP-689: Extend `StreamJoined` to allow more store configs

Thanks for looking into it. I also needed to refresh my memory. In Scala, it's sufficient to expose the `static` methods for a native Scala integration. If you look into the code, those static methods return the actually Java objects, and thus all non-static Java methods are available

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #256

See Changes: [github] KAFKA-10739; Replace EpochEndOffset with automated protocol (#9630) -- [...truncated 3.46 MB...]

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #279

See Changes: [github] KAFKA-10739; Replace EpochEndOffset with automated protocol (#9630) -- [...truncated 3.48 MB...]

[jira] [Created] (KAFKA-10805) More useful reporting from travis system tests

Jason Gustafson created KAFKA-10805: --- Summary: More useful reporting from travis system tests Key: KAFKA-10805 URL: https://issues.apache.org/jira/browse/KAFKA-10805 Project: Kafka Issue

Re: [VOTE] KIP-689: Extend `StreamJoined` to allow more store configs

+1 (binding) Thanks Leah! On Wed, Dec 2, 2020 at 11:27 AM Sophie Blee-Goldman wrote: > Thanks for the KIP! +1 (binding) > > Sophie > > On Wed, Dec 2, 2020 at 8:42 AM Walker Carlson > wrote: > > > +1 (non-binding) > > > > Thank you, > > walker > > > > On Wed, Dec 2, 2020 at 8:15 AM Bruno

[jira] [Created] (KAFKA-10804) Tune travis system tests to avoid timeouts

Jason Gustafson created KAFKA-10804: --- Summary: Tune travis system tests to avoid timeouts Key: KAFKA-10804 URL: https://issues.apache.org/jira/browse/KAFKA-10804 Project: Kafka Issue Type:

Re: Can I get a review for a documentation update (KAFKA-10473)?

Hello James, I will take a look at your PR. Thanks for the contribution! Guozhang On Wed, Dec 2, 2020 at 5:59 PM James Cheng wrote: > Hi, > > Can I get a review for this small documentation update? > > Thanks, > -James > > > On Oct 9, 2020, at 5:23 PM, James Cheng wrote: > > > > Hi, > > > >

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #278

See Changes: [github] KAFKA-10460: ReplicaListValidator format checking is incomplete (#9326) -- [...truncated 3.49 MB...]

[jira] [Resolved] (KAFKA-10739) Replace EpochEndOffset with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-10739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-10739. - Resolution: Done > Replace EpochEndOffset with automated protocol >

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #255

See Changes: [github] KAFKA-10460: ReplicaListValidator format checking is incomplete (#9326) -- [...truncated 3.46 MB...]

[DISCUSS] KIP-692: Make AdminClient value object constructors public

Hi there, I finally got around to write up the KIP for a change I have wanted for some time: KIP-692: Make AdminClient value object constructors public In essence: Let us encourage

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #301

See Changes: [github] KAFKA-10460: ReplicaListValidator format checking is incomplete (#9326) -- [...truncated 3.48 MB...]

[jira] [Created] (KAFKA-10803) Skip improper dynamic configs while initialization and include the rest correct ones

Prateek Agarwal created KAFKA-10803: --- Summary: Skip improper dynamic configs while initialization and include the rest correct ones Key: KAFKA-10803 URL: https://issues.apache.org/jira/browse/KAFKA-10803

Re: [DISCUSS] KIP-660: Pluggable ReplicaAssignor

Hi Colin thanks for your comments. I think your objections to creating an interface for replica placement could be used against similar server-side plug-ins (Authorizer, QuotaCallback). They too are on sensitive code paths, can cause problems if badly written/poorly tested and may cause a pain on

Re: [DISCUSS] KIP-690 Add additional configuration to control MirrorMaker 2 internal topics naming convention

Hi Omnia, Thanks for the KIP. Indeed being able to configure MM2's internal topic names would be a nice improvement. Looking at the KIP, I was surprised you propose an interface to allow users to specify names. Have you considered making names changeable via configurations? If so, we should

Re: [DISCUSS] KIP-689: Extend `StreamJoined` to allow more store configs

Thanks for thinking of that Matthias. After looking at what we currently have for `StreamJoined` in scala, we just have bare bones functionality, allowing users to use `StreamJoined` through the two `with()` functions and one `as()` function. This is the same for `Materialized` in scala, which

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #254

See Changes: [github] KAFKA-10554; Perform follower truncation based on diverging epochs in Fetch response (#9382) -- [...truncated 6.90 MB...]

[jira] [Resolved] (KAFKA-10460) ReplicaListValidator format checking is incomplete

[ https://issues.apache.org/jira/browse/KAFKA-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-10460. Fix Version/s: 2.8.0 Resolution: Fixed > ReplicaListValidator format checking is

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #277

See Changes: [github] KAFKA-10554; Perform follower truncation based on diverging epochs in Fetch response (#9382) -- [...truncated 3.49 MB...]

[jira] [Resolved] (KAFKA-10566) Erroneous unknown config warnings about ssl and sasl configs

[ https://issues.apache.org/jira/browse/KAFKA-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley resolved KAFKA-10566. - Resolution: Duplicate > Erroneous unknown config warnings about ssl and sasl configs >

[jira] [Resolved] (KAFKA-10554) Perform follower truncation based on epoch offsets returned in Fetch response

[ https://issues.apache.org/jira/browse/KAFKA-10554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-10554. Reviewer: Jason Gustafson Resolution: Fixed > Perform follower truncation based on

Re: [VOTE] 2.6.1 RC2

Thanks for the report Gary. Guozhang, I've opened https://issues.apache.org/jira/browse/KAFKA-10802. It's currently not marked as a blocker for 2.6.1. On Tue, Dec 1, 2020 at 6:40 PM Guozhang Wang wrote: > > Hello Gary, > > Thanks for pointing this out, that change was for making other

[jira] [Created] (KAFKA-10802) Spurious log message when starting consumers

Mickael Maison created KAFKA-10802: -- Summary: Spurious log message when starting consumers Key: KAFKA-10802 URL: https://issues.apache.org/jira/browse/KAFKA-10802 Project: Kafka Issue Type:

Re: Config command to describe SSL certificate paramters

Hello, Igor. Yes, we can. But, it requires access a. To the broker server via SSH b. To the JKS file itself: One who wants to get params must know JKS password and has read permission for the file. It seems to me that this kind of permissions is too high for a simple «know

Re: Config command to describe SSL certificate paramters

Hi Nikolay, You can use OpenSSL s_client to check all these things. https://www.openssl.org/docs/manmaster/man1/s_client.html -- Igor On Wed, Dec 2, 2020, at 5:44 PM, Nikolay Izhikov wrote: > Hello. > > Kafka has an ability to configure SSL connections between brokers and clients. > SSL

[jira] [Resolved] (KAFKA-10801) Docs on configuration have multiple places using the same HTML anchor tag

[ https://issues.apache.org/jira/browse/KAFKA-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley resolved KAFKA-10801. - Resolution: Fixed > Docs on configuration have multiple places using the same HTML anchor tag >