[jira] [Resolved] (KAFKA-3921) Periodic refresh of metadata causes spurious log messages

[ https://issues.apache.org/jira/browse/KAFKA-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3921. -- Resolution: Auto Closed Closing inactive issue. The old producer is no longer supported. Please upgrade

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

See

[jira] [Resolved] (KAFKA-6837) Apache kafka broker got stopped.

[ https://issues.apache.org/jira/browse/KAFKA-6837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6837. -- Resolution: Information Provided > Apache kafka broker got stopped. > >

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

See Changes: [wangguoz] MINOR: Build and code sample updates for Kafka Streams DSL for Scala -- [...truncated 420.01 KB...] kafka.admin.ResetConsumerGroupOffsetTest > test

Re: Requesting wiki access for creating a KIP

NP. :) Done. You should be able to create and edit pages now. -Matthias On 5/6/18 9:18 PM, Jeff Widman wrote: > My apologies, my username is "jeffwidman". > > > > I forgot confluence isn't a search by user email system. > > On Sun, May 6, 2018 at 7:53 PM, Matthias J. Sax > wrote: > >> Wha

Re: Requesting wiki access for creating a KIP

My apologies, my username is "jeffwidman". I forgot confluence isn't a search by user email system. On Sun, May 6, 2018 at 7:53 PM, Matthias J. Sax wrote: > What's your user id? Could not find a user `j...@jeffwidman.com` > > -Matthias > > On 5/6/18 11:12 AM, Jeff Widman wrote: > > I thought

Re: [DISCUSS] KIP-290: Support for wildcard suffixed ACLs

Makes sense. I'll update the KIP. Does anyone have any other comments? :) Thanks Piyush Vijay On Thu, May 3, 2018 at 11:55 AM, Colin McCabe wrote: > Yeah, I guess that's a good point. It probably makes sense to support the > prefix scheme for consumer groups and transactional IDs as well as

Re: KIP-244: Add Record Header support to Kafka Streams

I agree, that we should not block this KIP if possible. Nevertheless, we should try to get a reasonable default strategy for inheriting the headers so we don't need to change it later on. Let's see what other think. I still tend slightly to set to `null` by default for all cases. If the default st

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

Thanks. To reverse the question: if this argument holds, why does it not apply to the case when the header key is used as compaction attribute? I am not against keeping both records in case timestamps are equal, but shouldn't we apply the same strategy for all cases and don't use offset as tie-br

Re: KIP-244: Add Record Header support to Kafka Streams

Matthias, thanks for sharing your opinions in the inheritance protocol of the record context. I'm thinking maybe we should make this discussion as a separate KIP by itself? If yes, then KIP-244's scope would be smaller, and within KIP-244 we can have a simple inheritance rule that setting it to nul

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

Hello Matthias, The related discussion was in the PR: https://github.com/apache/kafka/pull/4822#discussion_r184588037 The concern is that, to use offset as tie breaker we need to double the entry size of the entry in bounded compaction cache, and hence largely reduce the effectiveness of the comp

Re: Request for Permission to Write KIP

Hello Allen, Thanks for your interests contributing to Kafka. I've added you to the contributor list and now you can create new KIPs. Guozhang On Sun, May 6, 2018 at 6:02 PM, Allen Tang wrote: > Hello! > > I am a new developer to the Apache Kafka project and I would like to write > up some KI

Request for Permission to Write KIP

Hello! I am a new developer to the Apache Kafka project and I would like to write up some KIPs to review/discuss with the Apache Kafka dev community. My Wiki ID is: atang https://cwiki.apache.org/confluence/display/~atang Thanks! Cheers, Allen

Re: Requesting wiki access for creating a KIP

What's your user id? Could not find a user `j...@jeffwidman.com` -Matthias On 5/6/18 11:12 AM, Jeff Widman wrote: > I thought I already had wiki access, but apparently I don't... > > Can someone give j...@jeffwidman.com proper permissions for creating a new > KIP? > > Thanks! > signature.as

Requesting wiki access for creating a KIP

I thought I already had wiki access, but apparently I don't... Can someone give j...@jeffwidman.com proper permissions for creating a new KIP? Thanks! -- *Jeff Widman* jeffwidman.com | 740-WIDMAN-J (943-6265) <><

Re: KIP-244: Add Record Header support to Kafka Streams

Making the inheritance protocol a public contract seems reasonable to me. In the current implementation, all output records inherits the offset, timestamp, topic, and partition metadata from the input record. We already added an API to change the timestamp explicitly for the output record thought.

Re: [DISCUSS] KIP-292: Add transformValues() method to KTable

Andy, thanks for the KIP. I don't have any further comments. My 2cents about Guozhang's questions: as I like consistent behavior, I think transfromValues() should behave the same way as filter() and mapValues(). -Matthias On 5/2/18 2:24 PM, Guozhang Wang wrote: > Hello Andy, > > Thanks for th

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

Hi, I just updated myself on this KIP. One question (maybe it was discussed and I missed it). What is the motivation to not use the offset as tie breaker for the "timestamp" case? Isn't this inconsistent behavior? -Matthias On 5/2/18 2:07 PM, Guozhang Wang wrote: > Hello Luís, > > Sorry for t