> On Mar 13, 2017, at 12:30 PM, Matthias J. Sax wrote:
>
> Jay,
>
> thanks for your feedback
>
>> What if instead we called it KStreamsBuilder?
>
> That's the current name and I personally think it's not the best one.
> The main reason why I don't like KStreamsBuilder is, that we have the
> c
> On Apr 7, 2017, at 5:12 PM, Gwen Shapira wrote:
>
> Hello Kafka users, developers and client-developers,
>
> This is the first candidate for the release of Apache Kafka 0.10.2.1. This
> is a bug fix release and it includes fixes and improvements from 24 JIRAs
> (including a few critical bugs)
Hi dev@,
I recently signed up for the Kafka Wiki as 'stevenschlansker' and would like to
contribute a KIP.
May I please have edit access to do so? Thanks!
signature.asc
Description: Message signed with OpenPGP using GPGMail
wrote:
>>>>> Steven,
>>>>>
>>>>> Thanks for your KIP. I move this discussion to dev mailing list --
>> KIPs
>>>>> need to be discussed there (and can be cc'ed to user list).
>>>>>
>>>>> Can you also
just be a
>>> special impl of `peek()` then, like we did for `count` as for `aggregate`?
>>> I.e. we can replace the `KeyValuePrinter` class with an internal ForEach
>>> impl within `peek()`.
>>>
>>>
>>> Guozhang
>>>
>>>
&g
Hi everyone,
Thank you for constructive feedback on KIP-121, KStream.peek(ForeachAction) ;
it seems like it is time to call a vote which I hope will pass easily :)
https://cwiki.apache.org/confluence/display/KAFKA/KIP-121%3A+Add+KStream+peek+method
I believe the PR attached is already in good sh
ra wrote:
>> +1 (binding)
>>
>> On Wed, Feb 8, 2017 at 4:45 PM, Steven Schlansker
>> wrote:
>>> Hi everyone,
>>>
>>> Thank you for constructive feedback on KIP-121,
>>> KStream.peek(ForeachAction) ;
>>> it seems like it is ti
rtly :)
> On Feb 14, 2017, at 3:36 PM, Zakee wrote:
>
> +1
>
> -Zakee
>> On Feb 14, 2017, at 1:56 PM, Jay Kreps wrote:
>>
>> +1
>>
>> Nice improvement.
>>
>> -Jay
>>
>> On Tue, Feb 14, 2017 at 1:22 PM, Steven Schlansker &
Oops, sorry, a number of votes were sent only to -dev and not to
-user and so I missed those in the email I just sent. The actual count is more
like +8
> On Feb 15, 2017, at 12:24 PM, Steven Schlansker
> wrote:
>
> From reading the bylaws it's not entirely clear who close
> On May 8, 2017, at 11:14 AM, BigData dev wrote:
>
> Hi All,
> I want to start a discussion on this simple KIP for Kafka Streams reset
> tool (kafka-streams-application-reset.sh).
> https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=69410150
I've not used this tool, but if I were
Java 6 has been End of Life since Feb 2013.
Java 7 (and 8, but unfortunately that's too new still) has very compelling
features which can make development a lot easier.
The sooner more projects drop Java 6 the better, in my opinion :)
On Nov 5, 2014, at 7:45 PM, Worthy LaFollette wrote:
> Mostl
Steven Schlansker created KAFKA-6767:
Summary: OffsetCheckpoint write assumes parent directory exists
Key: KAFKA-6767
URL: https://issues.apache.org/jira/browse/KAFKA-6767
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050793#comment-16050793
]
Steven Schlansker commented on KAFKA-4829:
--
This is talking about applica
[
https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050793#comment-16050793
]
Steven Schlansker edited comment on KAFKA-4829 at 6/15/17 5:1
Steven Schlansker created KAFKA-3921:
Summary: Periodic refresh of metadata causes spurious log messages
Key: KAFKA-3921
URL: https://issues.apache.org/jira/browse/KAFKA-3921
Project: Kafka
Steven Schlansker created KAFKA-4829:
Summary: Improve logging of StreamTask commits
Key: KAFKA-4829
URL: https://issues.apache.org/jira/browse/KAFKA-4829
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Schlansker updated KAFKA-4829:
-
Description:
Currently I see this every commit interval:
{code}
2017-02-28T21:27:16.659Z
[
https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Schlansker updated KAFKA-4829:
-
Description:
Currently I see this every commit interval:
{code}
2017-02-28T21:27:16.659Z
Steven Schlansker created KAFKA-4720:
Summary: Add KStream.peek(ForeachAction)
Key: KAFKA-4720
URL: https://issues.apache.org/jira/browse/KAFKA-4720
Project: Kafka
Issue Type: New
Steven Schlansker created KAFKA-4721:
Summary: KafkaStreams (and possibly others) should inherit
Closeable
Key: KAFKA-4721
URL: https://issues.apache.org/jira/browse/KAFKA-4721
Project: Kafka
Steven Schlansker created KAFKA-4722:
Summary: StreamThread should allow customization of thread prefix
Key: KAFKA-4722
URL: https://issues.apache.org/jira/browse/KAFKA-4722
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849098#comment-15849098
]
Steven Schlansker commented on KAFKA-4722:
--
I have multiple different functi
[
https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15850243#comment-15850243
]
Steven Schlansker commented on KAFKA-4722:
--
That would be perfect, th
Steven Schlansker created KAFKA-4726:
Summary: ValueMapper should have (read) access to key
Key: KAFKA-4726
URL: https://issues.apache.org/jira/browse/KAFKA-4726
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-4726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Schlansker updated KAFKA-4726:
-
Description:
{{ValueMapper}} should have read-only access to the key for the value it is
Steven Schlansker created KAFKA-4787:
Summary: KafkaStreams close() is not reentrant
Key: KAFKA-4787
URL: https://issues.apache.org/jira/browse/KAFKA-4787
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-4787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15879019#comment-15879019
]
Steven Schlansker commented on KAFKA-4787:
--
A simple solution could simply
[
https://issues.apache.org/jira/browse/KAFKA-4787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15879336#comment-15879336
]
Steven Schlansker commented on KAFKA-4787:
--
I'm not sure I understand
Steven Schlansker created KAFKA-13593:
-
Summary: ThrottledChannelReaper slows broker shutdown by multiple
seconds
Key: KAFKA-13593
URL: https://issues.apache.org/jira/browse/KAFKA-13593
Project
[
https://issues.apache.org/jira/browse/KAFKA-13593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Schlansker resolved KAFKA-13593.
---
Resolution: Fixed
> ThrottledChannelReaper slows broker shutdown by multi
Steven Schlansker created KAFKA-14942:
-
Summary: CopyOnWriteMap implements ConcurrentMap but does not
implement required default methods
Key: KAFKA-14942
URL: https://issues.apache.org/jira/browse/KAFKA-14942
[
https://issues.apache.org/jira/browse/KAFKA-14942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Schlansker resolved KAFKA-14942.
---
Resolution: Invalid
> CopyOnWriteMap implements ConcurrentMap but does
[
https://issues.apache.org/jira/browse/KAFKA-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15993414#comment-15993414
]
Steven Schlansker commented on KAFKA-1313:
--
I started using Kafka Str
[
https://issues.apache.org/jira/browse/KAFKA-1456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14017270#comment-14017270
]
Steven Schlansker commented on KAFKA-1456:
--
lz4-java tracks the lack of
Steven Schlansker created KAFKA-18689:
-
Summary: NoSuchElementException in state store iterator metrics
Key: KAFKA-18689
URL: https://issues.apache.org/jira/browse/KAFKA-18689
Project: Kafka
Steven Schlansker created KAFKA-19165:
-
Summary: PartitionLeaderStrategy has very high error rate during
topic initialization
Key: KAFKA-19165
URL: https://issues.apache.org/jira/browse/KAFKA-19165
36 matches
Mail list logo
