Re: [DISCUSSION] KIP-300: Add Windowed KTable API in StreamsBuilder

Hey friends, I know this is critical time for the 2.0 release. Just want to call out again for further review on the API format. Any feedback would be appreciated, thank you! Boyang From: Liquan Pei Sent: Tuesday, May 22, 2018 4:29 AM

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

See

[jira] [Resolved] (KAFKA-6911) Incorrect check for keystore/truststore dynamic update

[ https://issues.apache.org/jira/browse/KAFKA-6911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6911. Resolution: Fixed > Incorrect check for keystore/truststore dynamic update >

[jira] [Created] (KAFKA-6946) Keep the fetch session id for incremental fetch when

Jon Lee created KAFKA-6946: -- Summary: Keep the fetch session id for incremental fetch when Key: KAFKA-6946 URL: https://issues.apache.org/jira/browse/KAFKA-6946 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6945) Add support to allow users to acquire delegation tokens for other users

Manikumar created KAFKA-6945: Summary: Add support to allow users to acquire delegation tokens for other users Key: KAFKA-6945 URL: https://issues.apache.org/jira/browse/KAFKA-6945 Project: Kafka

[jira] [Created] (KAFKA-6944) Add system tests testing the new throttling behavior using older clients/brokers

Jon Lee created KAFKA-6944: -- Summary: Add system tests testing the new throttling behavior using older clients/brokers Key: KAFKA-6944 URL: https://issues.apache.org/jira/browse/KAFKA-6944 Project: Kafka

[jira] [Resolved] (KAFKA-6862) test toolchain

[ https://issues.apache.org/jira/browse/KAFKA-6862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6862. -- Resolution: Invalid Please reopen the Jira with more details. > test toolchain > -- > >

Re: [VOTE] KIP-228 Negative record timestamp support

Thanks Konstantin, I have a minor comment on the wiki page's "Proposed Solution" section: "The solution is to ignore that problem and it is a choice of the user to..": -- I'd suggest we rephrase it and admit "-1 is a special value in Kafka, which means we do not have a valid way to

RE: [DISCUSS] KIP-302 - Enable Kafka clients to use all DNS resolved IP addresses

Hi, As Rajini suggested in the thread for KIP 235 (attached), we could try to have an enum that would drive what does the client expands/resolves. I suggest a client config called client.dns.lookup with different values possible : - no : no dns lookup - hostnames.only : perform dns lookup on

Re: [VOTE] KIP-176: Remove deprecated new-consumer option for tools

+1 (non-binding) I like this KIP. The new-consumer option is actually sometimes confusing, commands could work without it and 2.0.0 seems like a good time to do it. We should make sure to add enough tests to provide coverage. On Wed, May 23, 2018 at 7:32 PM, Ted Yu wrote:

[jira] [Created] (KAFKA-6943) Have option to shutdown KS cleanly if any task crashes, or if all tasks crash

Antony Stubbs created KAFKA-6943: Summary: Have option to shutdown KS cleanly if any task crashes, or if all tasks crash Key: KAFKA-6943 URL: https://issues.apache.org/jira/browse/KAFKA-6943 Project:

[jira] [Created] (KAFKA-6942) Connect connectors api doesn't show versions of connectors

Antony Stubbs created KAFKA-6942: Summary: Connect connectors api doesn't show versions of connectors Key: KAFKA-6942 URL: https://issues.apache.org/jira/browse/KAFKA-6942 Project: Kafka

Re: [VOTE] KIP-278: Add version option to Kafka's commands

Hi all, This KIP would be accepted with 3 binding votes (Jason Gustafson, Guozhang Wang, Rajini Sivaram) and 7 non-binding votes. Thank you for participating. Thanks, Sasaki 2018-05-21 18:27 GMT+09:00 Rajini Sivaram : Hi Sasaki, Thanks for the KIP! +1 (binding)

[jira] [Resolved] (KAFKA-4505) Cannot get topic lag since kafka upgrade from 0.8.1.0 to 0.10.1.0

[ https://issues.apache.org/jira/browse/KAFKA-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4505. -- Resolution: Auto Closed {color:#00}Closing inactive issue. Please reopen if you think the issue

[jira] [Resolved] (KAFKA-2036) Consumer and broker have different networks

[ https://issues.apache.org/jira/browse/KAFKA-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2036. -- Resolution: Duplicate Resolving this duplicate of KIP-235/KIP-302  > Consumer and broker have

[jira] [Resolved] (KAFKA-3793) Kafka Python Consumer library messages gets truncated

[ https://issues.apache.org/jira/browse/KAFKA-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3793. -- Resolution: Cannot Reproduce {color:#00}Closing inactive issue. Please reopen if you think the

[jira] [Created] (KAFKA-6941) when passing port = 0 to worker, the advertisedPort still is 0 rather than a random port

Chia-Ping Tsai created KAFKA-6941: - Summary: when passing port = 0 to worker, the advertisedPort still is 0 rather than a random port Key: KAFKA-6941 URL: https://issues.apache.org/jira/browse/KAFKA-6941

Re: [DISCUSS] KIP-280: Enhanced log compaction

Hi Jun / Ismael, Any chance to get your opinion on this? Thanks in advance! Regards, Luís > On 22 May 2018, at 17:30, Guozhang Wang wrote: > > Hello Luís, > > While reviewing your PR I realized my previous calculation on the memory > usage was incorrect: in fact, in the

[jira] [Created] (KAFKA-6940) Kafka Cluster and Zookeeper ensemble configuration with SASL authentication

Shashank Jain created KAFKA-6940: Summary: Kafka Cluster and Zookeeper ensemble configuration with SASL authentication Key: KAFKA-6940 URL: https://issues.apache.org/jira/browse/KAFKA-6940 Project: