[jira] [Resolved] (KAFKA-6396) Possibly kafka-connect converter should be able to stop processing chain

[ https://issues.apache.org/jira/browse/KAFKA-6396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Koval resolved KAFKA-6396. Resolution: Invalid Thank you for the explanation. > Possibly kafka-connect converter

[jira] [Created] (KAFKA-6604) ReplicaManager should not remove partitions on the log dirctory from high watermark checkpoint file

Dong Lin created KAFKA-6604: --- Summary: ReplicaManager should not remove partitions on the log dirctory from high watermark checkpoint file Key: KAFKA-6604 URL: https://issues.apache.org/jira/browse/KAFKA-6604

Re: [VOTE] 1.1.0 RC0

Thanks Jason. Assuming the system tests pass i'll cut RC1 tomorrow. Thanks, Damian On Thu, 1 Mar 2018 at 19:10 Jason Gustafson wrote: > The fix has been merged to 1.1. > > Thanks, > Jason > > On Wed, Feb 28, 2018 at 11:35 AM, Damian Guy wrote: > > >

[jira] [Created] (KAFKA-6605) Flatten SMT does not properly handle fields that are null

Randall Hauch created KAFKA-6605: Summary: Flatten SMT does not properly handle fields that are null Key: KAFKA-6605 URL: https://issues.apache.org/jira/browse/KAFKA-6605 Project: Kafka

Re: [kafka-clients] Re: [VOTE] 1.1.0 RC0

Hi, Damian, It would also be useful to include KAFKA-6111, which prevents deleteLogDirEventNotifications path to be deleted correctly from Zookeeper. The patch should be committed later today. Thanks, Jun On Thu, Mar 1, 2018 at 1:47 PM, Damian Guy wrote: > Thanks Jason.

Re: [VOTE] 1.1.0 RC0

The fix has been merged to 1.1. Thanks, Jason On Wed, Feb 28, 2018 at 11:35 AM, Damian Guy wrote: > Hi Jason, > > Ok - thanks. Let me know how you get on. > > Cheers, > Damian > > On Wed, 28 Feb 2018 at 19:23 Jason Gustafson wrote: > > > Hey Damian, >

[jira] [Resolved] (KAFKA-6593) Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6593. Resolution: Fixed > Coordinator disconnect in heartbeat thread can cause commitSync to

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

See Changes: [github] KAFKA-6560: Replace range query with newly added single point query in -- [...truncated 3.92 MB...]

[jira] [Resolved] (KAFKA-3513) Transient failure of OffsetValidationTest

[ https://issues.apache.org/jira/browse/KAFKA-3513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3513. Resolution: Fixed We haven't seen this in some time, so I'm going to close this. We can

Jenkins build is back to normal : kafka-trunk-jdk7 #3220

See

Re: [DISCUSS] KIP-211: Revise Expiration Semantics of Consumer Group Offsets

Hi Jason, Thanks for your feedback. If we want to keep the per-partition expiration timestamp, then the scope of the KIP will be significantly reduced. In other words, we will just be deleting offsets from cache as before but only if the group is in Empty state. This would not cause any

[jira] [Created] (KAFKA-6603) Kafka streams off heap memory usage does not match expected values from configuration

Igor Calabria created KAFKA-6603: Summary: Kafka streams off heap memory usage does not match expected values from configuration Key: KAFKA-6603 URL: https://issues.apache.org/jira/browse/KAFKA-6603

Re: [DISCUSS] KIP-211: Revise Expiration Semantics of Consumer Group Offsets

Correction. The offsets will be removed when the expiration timestamp is reached. We will be setting the expiration timestamp in a smart manner to cover both the issue reported in the JIRA, and also the case of unsubscribed topics. I'll detail this in the KIP, and send a notification when the

[jira] [Resolved] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators

[ https://issues.apache.org/jira/browse/KAFKA-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6560. -- Resolution: Fixed Fix Version/s: 1.2.0 > Use single-point queries than range queries for

[jira] [Created] (KAFKA-6602) Support Kafka to save credentials in Java Key Store on Zookeeper node

Chen He created KAFKA-6602: -- Summary: Support Kafka to save credentials in Java Key Store on Zookeeper node Key: KAFKA-6602 URL: https://issues.apache.org/jira/browse/KAFKA-6602 Project: Kafka

Re: [VOTE] KIP-261: Add Single Value Fetch in Window Stores

+1 from myself. I'm going to close the vote with the following results: binding +1s: 3 (Matthias, Damian, Guozhang) non-binding +1s: 2 (Ted, Bill) Thanks for everyone who have participated in the discussion and voted! Guozhang On Sat, Feb 24, 2018 at 3:51 PM, Matthias J. Sax

[DISCUSS] KIP-265: Make Windowed Serde to public APIs

Hello all, I'd like to have a discussion on making windowed serde to public APIs of Kafka Streams. It involves a couple of new configs, plus a few new public classes for windowed serializer and deserializer, and also adding the corresponding console consumer options in order to fetch from a topic

Re: [DISCUSS] KIP-253: Support in-order message delivery with partition expansion

Hey Jason, Thanks much for all the valuable feedback! On Wed, Feb 28, 2018 at 11:09 AM, Jason Gustafson wrote: > Hi Dong, > > Great work on this proposal! Just a couple initial comments: > > My understanding is that the consumer will block on a topic until the all >

答复: [DISCUSS] KIP-265: Make Windowed Serde to public APIs

Guozhang, Thanks for this KIP. Please help confirm questions below: 1. Do we also need to retrofit `SimpleConsumerShell` to have it support these newly-added serdes? 2. Does this KIP cover the changes for ConsoleConsumer as well? 发件人: Guozhang Wang

Re: [DISCUSS] KIP-253: Support in-order message delivery with partition expansion

Hi Dong, On Tue, Feb 27, 2018 at 10:07 PM, Dong Lin wrote: > Hey Allen, > > Thanks for the comments. > > On Mon, Feb 26, 2018 at 9:27 PM, Allen Wang > wrote: > > > Hi Dong, > > > > Please see my comments inline. > > > > Thanks, > > Allen > > >

[jira] [Resolved] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-6592. --- Resolution: Duplicate Seems it's a duplicate of

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

See Changes: [github] KAFKA-6593; Fix livelock with consumer heartbeat thread in commitSync -- [...truncated 3.50 MB...] kafka.server.KafkaApisTest >

Re: [kafka-clients] Re: [VOTE] 1.1.0 RC0

KAFKA-6111 is now merged to 1.1 branch. Thanks, Jun On Thu, Mar 1, 2018 at 2:50 PM, Jun Rao wrote: > Hi, Damian, > > It would also be useful to include KAFKA-6111, which prevents > deleteLogDirEventNotifications path to be deleted correctly from > Zookeeper. The patch

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

See