[jira] [Created] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

igor mazor created KAFKA-6556: - Summary: allow to attach callbacks in kafka streams, to be triggered when a window is expired Key: KAFKA-6556 URL: https://issues.apache.org/jira/browse/KAFKA-6556

[jira] [Created] (KAFKA-6557) Kafka Consumer Offsets are unavailable during rebalancing

Wouter Bancken created KAFKA-6557: - Summary: Kafka Consumer Offsets are unavailable during rebalancing Key: KAFKA-6557 URL: https://issues.apache.org/jira/browse/KAFKA-6557 Project: Kafka

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

See

[jira] [Created] (KAFKA-6558) Pre-load topics metadata in Mirror maker

Michal Turek created KAFKA-6558: --- Summary: Pre-load topics metadata in Mirror maker Key: KAFKA-6558 URL: https://issues.apache.org/jira/browse/KAFKA-6558 Project: Kafka Issue Type: Improvement

StoreFactory deprecated? Any JIRA issue to work on?

Hi, While reviewing the code I've noticed that StoreFactory is used exclusively from Stores.create [1] which is deprecated. That gave me impression that StoreFactory should be deprecated/removed too. What about AbstractStream.storeFactory [2] and its uses then? Is there a JIRA issue to work on

[jira] [Resolved] (KAFKA-6472) WordCount example code error

[ https://issues.apache.org/jira/browse/KAFKA-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6472. Resolution: Fixed > WordCount example code error > > >

Jenkins build is back to normal : kafka-1.1-jdk7 #31

See

[jira] [Created] (KAFKA-6559) Iterate record sets before calling Log.append

Todd Palino created KAFKA-6559: -- Summary: Iterate record sets before calling Log.append Key: KAFKA-6559 URL: https://issues.apache.org/jira/browse/KAFKA-6559 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-6511) Connect header parser incorrectly parses arrays

[ https://issues.apache.org/jira/browse/KAFKA-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6511. Resolution: Fixed > Connect header parser incorrectly parses arrays >

Re: StoreFactory deprecated? Any JIRA issue to work on?

Jacek, thanks for reporting this. I agree that `StoreFactory` should be deprecated -- I guess it slipped in KIP-182. Because it's still a public class, this would require a KIP (should be straight forward to do, though). For `AbstractStream.storeFactory`, we don't need to deprecate it because

Re: [DISCUSS]KIP-216: IQ should throw different exceptions for different errors

Is there any update on this KIP? -Matthias On 1/3/18 12:59 AM, vito jeng wrote: > Matthias, > > Thank you for your response. > > I think you are right. We need to look at the state both of > KafkaStreams and StreamThread. > > After further understanding of KafkaStreams thread and state store,

Re: [DISCUSS]: KIP-230: Name Windowing Joins

Is there any updates for this KIP? -Matthias On 12/28/17 12:27 PM, Matthias J. Sax wrote: > Thanks for updating the KIP. > > The code-diff is a little hard to read. It's better to so something > similar as in this KIP: >

Build failed in Jenkins: kafka-trunk-jdk9 #395

See Changes: [jason] KAFKA-6511; Corrected connect list/map parsing logic (#4516) -- [...truncated 2.03 MB...] at

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

Hi Jorge, I would like to unblock this KIP to make some progress. The tricky question of this work, seems to be how to expose headers at DSL level. This related to KIP-149 and KIP-159. However, for Processor API, it seems to be rather straight forward to add headers to the API. Thus, I would

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

Guozhang Wang created KAFKA-6560: Summary: Use single-point queries than range queries for windowed aggregation operators Key: KAFKA-6560 URL: https://issues.apache.org/jira/browse/KAFKA-6560

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

Is there any update for this KIP? -Matthias On 12/4/17 2:08 PM, Matthias J. Sax wrote: > Jeyhun, > > thanks for updating the KIP. > > I am wondering if you intend to add a new class `Produced`? There is > already `org.apache.kafka.streams.kstream.Produced`. So if we want to > add a new class,

Jenkins build is back to normal : kafka-trunk-jdk9 #396

See

Re: [DISCUSS]: KIP-230: Name Windowing Joins

Thanks for the reminder! I need to do some wordsmithing based on the feedback I’ve gotten. I’ll do that soon (hopefully). On Tue, Feb 13, 2018 at 1:45 PM Matthias J. Sax wrote: > Is there any updates for this KIP? > > -Matthias > > On 12/28/17 12:27 PM, Matthias J. Sax

[jira] [Created] (KAFKA-6561) Change visibility of aclMatch in SimpleAclAuthorizer to protected to allow overriding in subclasses

Sönke Liebau created KAFKA-6561: --- Summary: Change visibility of aclMatch in SimpleAclAuthorizer to protected to allow overriding in subclasses Key: KAFKA-6561 URL: https://issues.apache.org/jira/browse/KAFKA-6561

[jira] [Resolved] (KAFKA-4221) KafkaConsumer Fetcher can send ListOffsets requests in parallel when initializing position

[ https://issues.apache.org/jira/browse/KAFKA-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4221. Resolution: Fixed > KafkaConsumer Fetcher can send ListOffsets requests in parallel when >

[jira] [Resolved] (KAFKA-4221) KafkaConsumer Fetcher can send ListOffsets requests in parallel when initializing position

[ https://issues.apache.org/jira/browse/KAFKA-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4221. Resolution: Duplicate > KafkaConsumer Fetcher can send ListOffsets requests in parallel

[jira] [Reopened] (KAFKA-4221) KafkaConsumer Fetcher can send ListOffsets requests in parallel when initializing position

[ https://issues.apache.org/jira/browse/KAFKA-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-4221: > KafkaConsumer Fetcher can send ListOffsets requests in parallel when > initializing position

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

See Changes: [wangguoz] MINOR: Misc improvements on runtime / storage / metrics / config parts [wangguoz] MINOR: fix inconsistance in LogCleaner javadoc (#4027) [wangguoz] MINOR: more details in error message