Re: [DISCUSS] KIP-110: Add Codec for ZStandard Compression (Updated)

Hi Jason, You are right. Explicit statements are always better. I updated the document following your suggestion. @Magnus Thanks for the inspection. It seems like a new error code is not a problem. Thanks, Dongjin On Fri, Sep 7, 2018 at 3:23 AM Jason Gustafson wrote: > Hi Dongjin, > > The KI

Re: [DISCUSS] Apache Kafka 2.1.0 Release Plan

Thanks a lot! You are on a run after 1.1.1 release. I see something coming up for myself in 4 month. :) On 9/9/18 6:15 PM, Guozhang Wang wrote: > Dong, thanks for driving the release! > > On Sun, Sep 9, 2018 at 5:57 PM, Ismael Juma wrote: > >> Thanks for volunteering Dong! >> >> Ismael >> >> O

Re: [VOTE] KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics

+1 Useful improvement, thanks Randall. On Fri, Sep 7, 2018, 3:28 PM Randall Hauch wrote: > I believe the feedback on KIP-158 has been addressed. I'd like to start a > vote. > > KIP: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-158%3A+Kafka+Connect+should+allow+source+connectors+to+

Re: [DISCUSS] Apache Kafka 2.1.0 Release Plan

Dong, thanks for driving the release! On Sun, Sep 9, 2018 at 5:57 PM, Ismael Juma wrote: > Thanks for volunteering Dong! > > Ismael > > On Sun, 9 Sep 2018, 17:32 Dong Lin, wrote: > > > Hi all, > > > > I would like to be the release manager for our next time-based feature > > release 2.1.0. > >

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

See

Re: [DISCUSS] Apache Kafka 2.1.0 Release Plan

Thanks for volunteering Dong! Ismael On Sun, 9 Sep 2018, 17:32 Dong Lin, wrote: > Hi all, > > I would like to be the release manager for our next time-based feature > release 2.1.0. > > The recent Kafka release history can be found at > https://cwiki.apache.org/confluence/display/KAFKA/Future+r

Jenkins build is back to normal : kafka-trunk-jdk10 #462

See

[DISCUSS] Apache Kafka 2.1.0 Release Plan

Hi all, I would like to be the release manager for our next time-based feature release 2.1.0. The recent Kafka release history can be found at https://cwiki.apache.org/confluence/display/KAFKA/Future+release+plan. The release plan (with open issues and planned KIPs) for 2.1.0 can be found at http

[jira] [Resolved] (KAFKA-4932) Add UUID Serde

[ https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4932. -- Resolution: Fixed Issue resolved by pull request 4438 [https://github.com/apach

Re: [VOTE] KIP-367 Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)

Thanks a lot for the KIP. +1 (binding) -Matthias On 9/8/18 11:27 AM, Chia-Ping Tsai wrote: > Hi All, > > I'd like to put KIP-367 to the vote. > > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=89070496 > > -- > Chia-Ping > signature.asc Description: OpenPGP digital sig

Re: [DISCUSS] KIP-367 Introduce close(Duration) to Producer instead of close(long, TimeUnit)

Thanks you! On 9/9/18 4:54 AM, Chia-Ping Tsai wrote: > Thanks for your comments! > >> - showing the signatures of methods is sufficient (no need to have >> implementation details in the KIP). >> >> - `KafkaAdminClient#close(long duration, TimeUnit unit)` should be >> added as deprecated in the

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

See Changes: [lindong28] KAFKA-7333; Protocol changes for KIP-320 -- [...truncated 2.68 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDiffer

[jira] [Created] (KAFKA-7392) Allow to specify subnet for Docker containers using standard CIDR notation

Attila Sasvari created KAFKA-7392: - Summary: Allow to specify subnet for Docker containers using standard CIDR notation Key: KAFKA-7392 URL: https://issues.apache.org/jira/browse/KAFKA-7392 Project: K

Re: [DISCUSS] KIP-367 Introduce close(Duration) to Producer instead of close(long, TimeUnit)

Thanks for your comments! > - showing the signatures of methods is sufficient (no need to have > implementation details in the KIP). > > - `KafkaAdminClient#close(long duration, TimeUnit unit)` should be > added as deprecated in the KIP, too > > - `AdminClient#close(long duration, TimeUnit un

Build failed in Jenkins: kafka-trunk-jdk10 #461

See Changes: [lindong28] KAFKA-7333; Protocol changes for KIP-320 -- [...truncated 2.21 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldUseSourceSpecificDe

Build failed in Jenkins: kafka-trunk-jdk10 #460

See Changes: [jason] KAFKA-7286; Avoid getting stuck loading large metadata records (#5500) -- [...truncated 2.17 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

[jira] [Resolved] (KAFKA-7286) Loading offsets and group metadata hangs with large group metadata records

[ https://issues.apache.org/jira/browse/KAFKA-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7286. Resolution: Fixed Fix Version/s: 2.1.0 > Loading offsets and group metadata hangs wi

[jira] [Resolved] (KAFKA-7333) Protocol changes for KIP-320

[ https://issues.apache.org/jira/browse/KAFKA-7333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-7333. - Resolution: Fixed > Protocol changes for KIP-320 > > > Key:

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

See