[jira] [Commented] (KAFKA-5233) Changes to punctuate semantics (KIP-138)

2017-07-30 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106404#comment-16106404 ] Matthias J. Sax commented on KAFKA-5233: I agree with [~mihbor] that we might want to keep the old

[jira] [Commented] (KAFKA-5677) Remove deprecated punctuate method

2017-07-30 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106405#comment-16106405 ] Matthias J. Sax commented on KAFKA-5677: Not sure if we should do this. See my comment on

[jira] [Commented] (KAFKA-5571) Possible deadlock during shutdown in setState in kafka streams 10.2

2017-07-07 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16078420#comment-16078420 ] Matthias J. Sax commented on KAFKA-5571: [~enothereska] Did some rework on state management in

[jira] [Created] (KAFKA-5603) Streams should not abort transaction when closing zombie task

2017-07-17 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5603: -- Summary: Streams should not abort transaction when closing zombie task Key: KAFKA-5603 URL: https://issues.apache.org/jira/browse/KAFKA-5603 Project: Kafka

[jira] [Updated] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

2017-07-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5167: --- Fix Version/s: 0.10.2.2 > streams task gets stuck after re-balance due to LockException >

[jira] [Resolved] (KAFKA-5577) WindowedStreamPartitioner does not provide topic name to serializer

2017-07-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5577. Resolution: Fixed Fixed via https://github.com/apache/kafka/pull/2776 >

[jira] [Created] (KAFKA-5577) WindowedStreamPartitioner does not provide topic name to serializer

2017-07-10 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5577: -- Summary: WindowedStreamPartitioner does not provide topic name to serializer Key: KAFKA-5577 URL: https://issues.apache.org/jira/browse/KAFKA-5577 Project: Kafka

[jira] [Commented] (KAFKA-4490) Add Global Table support to Kafka Streams

2017-07-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076901#comment-16076901 ] Matthias J. Sax commented on KAFKA-4490: See: https://issues.apache.org/jira/browse/KAFKA-4628 >

[jira] [Created] (KAFKA-5566) Instable test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied

2017-07-06 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5566: -- Summary: Instable test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied Key: KAFKA-5566 URL: https://issues.apache.org/jira/browse/KAFKA-5566

[jira] [Updated] (KAFKA-4819) Expose states of active tasks to public API

2017-07-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4819: --- Fix Version/s: 0.11.1.0 > Expose states of active tasks to public API >

[jira] [Commented] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic

2017-07-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16091762#comment-16091762 ] Matthias J. Sax commented on KAFKA-5386: For internal repartitioning topics, you can always avoid

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

2017-07-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094568#comment-16094568 ] Matthias J. Sax commented on KAFKA-4750: As mentioned above. I would go with option (1) as null

[jira] [Commented] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info

2017-07-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094886#comment-16094886 ] Matthias J. Sax commented on KAFKA-5618: [~yogeshbelur] I did have a look into the logs. They

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

2017-07-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095776#comment-16095776 ] Matthias J. Sax commented on KAFKA-4750: I understand what you are saying, but encoding an empty

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

2017-07-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095769#comment-16095769 ] Matthias J. Sax commented on KAFKA-4468: [~guozhang] We have to distinguish two cases: (1)

[jira] [Commented] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info

2017-07-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095784#comment-16095784 ] Matthias J. Sax commented on KAFKA-5618: Thanks for following up. If it hangs and the threads

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

2017-07-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16100120#comment-16100120 ] Matthias J. Sax commented on KAFKA-4327: [~jeqo] I assigned this to you, as it is be covered by

[jira] [Assigned] (KAFKA-4327) Move Reset Tool from core to streams

2017-07-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4327: -- Assignee: Jorge Quilcate (was: Matthias J. Sax) > Move Reset Tool from core to

[jira] [Comment Edited] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic

2017-07-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16098591#comment-16098591 ] Matthias J. Sax edited comment on KAFKA-5386 at 7/24/17 3:39 PM: - Well.

[jira] [Updated] (KAFKA-5632) Message headers not supported by Kafka Streams

2017-07-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5632: --- Labels: needs-kip (was: ) > Message headers not supported by Kafka Streams >

[jira] [Commented] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic

2017-07-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16098591#comment-16098591 ] Matthias J. Sax commented on KAFKA-5386: Well. With regard to ACL, you can still know the names of

[jira] [Updated] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic

2017-07-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5386: --- Labels: needs-kip (was: ) > [Kafka Streams] - custom name for state-store change-log topic >

[jira] [Commented] (KAFKA-5648) make Merger extend Aggregator

2017-07-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103319#comment-16103319 ] Matthias J. Sax commented on KAFKA-5648: The issue is, if one implements old {{Merger}} and does a

[jira] [Created] (KAFKA-5671) Add StreamsBuilder and deprecate KStreamBuilder

2017-07-27 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5671: -- Summary: Add StreamsBuilder and deprecate KStreamBuilder Key: KAFKA-5671 URL: https://issues.apache.org/jira/browse/KAFKA-5671 Project: Kafka Issue

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

2017-07-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16101659#comment-16101659 ] Matthias J. Sax commented on KAFKA-4327: It's Streams tool, so it belongs to package

[jira] [Commented] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic

2017-07-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16101652#comment-16101652 ] Matthias J. Sax commented on KAFKA-5386: Understood. Technically, it would be possible to allow

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

2017-07-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102134#comment-16102134 ] Matthias J. Sax commented on KAFKA-4327: It is definitely part of public API, and I am fine with

[jira] [Commented] (KAFKA-5648) make Merger extend Aggregator

2017-07-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102119#comment-16102119 ] Matthias J. Sax commented on KAFKA-5648: Your observation is correct, that {{Merger}} and

[jira] [Created] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

2017-07-26 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5660: -- Summary: Don't throw TopologyBuilderException during runtime Key: KAFKA-5660 URL: https://issues.apache.org/jira/browse/KAFKA-5660 Project: Kafka Issue

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

2017-07-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102357#comment-16102357 ] Matthias J. Sax commented on KAFKA-4327: Thanks [~ijuma]! This clarifies it. > Move Reset Tool

[jira] [Comment Edited] (KAFKA-4750) KeyValueIterator returns null values

2017-07-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097368#comment-16097368 ] Matthias J. Sax edited comment on KAFKA-4750 at 7/22/17 3:41 PM: - IMHO, we

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

2017-07-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097368#comment-16097368 ] Matthias J. Sax commented on KAFKA-4750: IMHO, we can also improve the code by not calling the

[jira] [Commented] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

2017-06-29 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16068951#comment-16068951 ] Matthias J. Sax commented on KAFKA-5530: Also, Kafka {{0.11.0.0}} was released today. It would be

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

2017-06-29 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16068935#comment-16068935 ] Matthias J. Sax commented on KAFKA-4468: [~evis] In

[jira] [Created] (KAFKA-5541) Streams should not re-throw if suspending/closing task fails

2017-06-29 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5541: -- Summary: Streams should not re-throw if suspending/closing task fails Key: KAFKA-5541 URL: https://issues.apache.org/jira/browse/KAFKA-5541 Project: Kafka

[jira] [Commented] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

2017-06-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16067362#comment-16067362 ] Matthias J. Sax commented on KAFKA-5167: [~habdank] Seems you created

[jira] [Commented] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

2017-06-30 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16070470#comment-16070470 ] Matthias J. Sax commented on KAFKA-5530: I see. If you apply different filters it makes totally

[jira] [Commented] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip

2017-06-30 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16070474#comment-16070474 ] Matthias J. Sax commented on KAFKA-5545: Hi. The messages with the stack trace {noformat}

[jira] [Comment Edited] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip

2017-06-30 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16070474#comment-16070474 ] Matthias J. Sax edited comment on KAFKA-5545 at 6/30/17 5:54 PM: - Hi. The

[jira] [Commented] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

2017-07-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072596#comment-16072596 ] Matthias J. Sax commented on KAFKA-5530: Glad you could resolve your problem. We did change the

[jira] [Commented] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip

2017-07-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072587#comment-16072587 ] Matthias J. Sax commented on KAFKA-5545: Can you do me a favor and attach the log file instead of

[jira] [Commented] (KAFKA-5528) Error while reading topic, offset, partition info from process method

2017-07-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072622#comment-16072622 ] Matthias J. Sax commented on KAFKA-5528: [~nravi] I guess the problem is, that you are using a

[jira] [Created] (KAFKA-5551) StreamThread should not expose methods for testing

2017-07-01 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5551: -- Summary: StreamThread should not expose methods for testing Key: KAFKA-5551 URL: https://issues.apache.org/jira/browse/KAFKA-5551 Project: Kafka Issue

[jira] [Commented] (KAFKA-5397) streams are not recovering from LockException during rebalancing

2017-07-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16075943#comment-16075943 ] Matthias J. Sax commented on KAFKA-5397: [~jozi-k] KAFKA-5167 got merged into {{trunk}} and

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

2017-07-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076830#comment-16076830 ] Matthias J. Sax commented on KAFKA-4468: Thanks for following up. About storing the window size --

[jira] [Commented] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

2017-07-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16075056#comment-16075056 ] Matthias J. Sax commented on KAFKA-5070: I was working on

[jira] [Reopened] (KAFKA-5528) Error while reading topic, offset, partition info from process method

2017-07-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5528: > Error while reading topic, offset, partition info from process method >

[jira] [Resolved] (KAFKA-5528) Error while reading topic, offset, partition info from process method

2017-07-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5528. Resolution: Not A Bug > Error while reading topic, offset, partition info from process

[jira] [Commented] (KAFKA-5528) Error while reading topic, offset, partition info from process method

2017-07-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16075191#comment-16075191 ] Matthias J. Sax commented on KAFKA-5528: Added FAQ:

[jira] [Commented] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

2017-06-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065664#comment-16065664 ] Matthias J. Sax commented on KAFKA-5167: The issue with multiple calls to {{close()}} is addressed

[jira] [Reopened] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

2017-06-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5167: This seems to got broken via

[jira] [Commented] (KAFKA-4344) Exception when accessing partition, offset and timestamp in processor class

2017-06-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065505#comment-16065505 ] Matthias J. Sax commented on KAFKA-4344: What version are you using? > Exception when accessing

[jira] [Updated] (KAFKA-5528) Error while reading topic, offset, partition info from process method

2017-06-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5528: --- Description: We are encountering an {{IllegalStateException}} while trying to access

[jira] [Commented] (KAFKA-4344) Exception when accessing partition, offset and timestamp in processor class

2017-06-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065609#comment-16065609 ] Matthias J. Sax commented on KAFKA-4344: You did create

[jira] [Resolved] (KAFKA-3745) Consider adding join key to ValueJoiner interface

2017-07-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3745. Resolution: Duplicate See

[jira] [Assigned] (KAFKA-3745) Consider adding join key to ValueJoiner interface

2017-07-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-3745: -- Assignee: Jeyhun Karimov (was: Sreepathi Prasanna) > Consider adding join key to

[jira] [Assigned] (KAFKA-4726) ValueMapper should have (read) access to key

2017-07-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4726: -- Assignee: Jeyhun Karimov > ValueMapper should have (read) access to key >

[jira] [Commented] (KAFKA-5318) Streams state may be misleading

2017-07-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077336#comment-16077336 ] Matthias J. Sax commented on KAFKA-5318: Is this contained by KAFKA-5372 ? \cc [~enothereska] >

[jira] [Updated] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

2017-07-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4125: --- Labels: kip (was: ) > Provide low-level Processor API meta data in DSL layer >

[jira] [Updated] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

2017-07-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4125: --- Description: For Processor API, user can get meta data like record offset, timestamp etc via

[jira] [Commented] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

2017-07-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104122#comment-16104122 ] Matthias J. Sax commented on KAFKA-5660: {{TopologyBuilderException}} got deprecated via KIP-120

[jira] [Updated] (KAFKA-5576) Support Power platform by updating rocksdb

2017-07-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5576: --- Component/s: streams > Support Power platform by updating rocksdb >

[jira] [Assigned] (KAFKA-5156) Options for handling exceptions in streams

2017-08-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5156: -- Assignee: Matthias J. Sax (was: Eno Thereska) > Options for handling exceptions in

[jira] [Created] (KAFKA-5765) Move merge() from StreamsBuilder to KStream

2017-08-22 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5765: -- Summary: Move merge() from StreamsBuilder to KStream Key: KAFKA-5765 URL: https://issues.apache.org/jira/browse/KAFKA-5765 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

2017-08-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5070. Resolution: Duplicate > org.apache.kafka.streams.errors.LockException: task [0_18] Failed

[jira] [Updated] (KAFKA-5603) Streams should not abort transaction when closing zombie task

2017-08-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5603: --- Fix Version/s: (was: 0.11.0.2) 0.11.0.1 > Streams should not abort

[jira] [Updated] (KAFKA-5474) Streams StandbyTask should no checkpoint on commit if EOS is enabled

2017-06-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5474: --- Fix Version/s: (was: 0.11.0.0) > Streams StandbyTask should no checkpoint on commit if

[jira] [Updated] (KAFKA-5474) Streams StandbyTask should no checkpoint on commit if EOS is enabled

2017-06-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5474: --- Affects Version/s: (was: 0.11.0.0) 0.11.1.0 > Streams StandbyTask

[jira] [Created] (KAFKA-5485) Streams should not suspend tasks twice

2017-06-20 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5485: -- Summary: Streams should not suspend tasks twice Key: KAFKA-5485 URL: https://issues.apache.org/jira/browse/KAFKA-5485 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2017-06-21 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5488: --- Labels: needs-kip (was: ) > KStream.branch should not return a Array of streams we have to

[jira] [Commented] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2017-06-21 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058103#comment-16058103 ] Matthias J. Sax commented on KAFKA-5488: Thanks for creating this JIRA. I agree that the index

[jira] [Updated] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2017-06-21 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5488: --- Affects Version/s: 0.11.0.0 > KStream.branch should not return a Array of streams we have to

[jira] [Created] (KAFKA-5489) Failing test: InternalTopicIntegrationTest.shouldCompactTopicsForStateChangelogs

2017-06-21 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5489: -- Summary: Failing test: InternalTopicIntegrationTest.shouldCompactTopicsForStateChangelogs Key: KAFKA-5489 URL: https://issues.apache.org/jira/browse/KAFKA-5489

[jira] [Updated] (KAFKA-4750) KeyValueIterator returns null values

2017-06-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4750: --- Affects Version/s: (was: 0.10.1.1) > KeyValueIterator returns null values >

[jira] [Updated] (KAFKA-4750) KeyValueIterator returns null values

2017-06-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4750: --- Affects Version/s: 0.10.2.1 > KeyValueIterator returns null values >

[jira] [Updated] (KAFKA-5510) Streams should commit all offsets regularly

2017-06-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5510: --- Description: Currently, Streams commits only offsets of partitions it did process records

[jira] [Updated] (KAFKA-5510) Streams should commit all offsets regularly

2017-06-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5510: --- Description: Currently, Streams commits only offsets of partitions it did process records

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

2017-06-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062112#comment-16062112 ] Matthias J. Sax commented on KAFKA-4750: Your observation is correct. I simplified the call chain.

[jira] [Reopened] (KAFKA-4262) Intermittent unit test failure ReassignPartitionsClusterTest.shouldExecuteThrottledReassignment

2017-06-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4262: This happened again

[jira] [Created] (KAFKA-5510) Streams should commit all offsets regularly

2017-06-24 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5510: -- Summary: Streams should commit all offsets regularly Key: KAFKA-5510 URL: https://issues.apache.org/jira/browse/KAFKA-5510 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5464) StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG

2017-06-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5464: --- Fix Version/s: 0.11.1.0 > StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG >

[jira] [Updated] (KAFKA-5464) StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG

2017-06-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5464: --- Fix Version/s: 0.11.0.1 0.10.2.2 > StreamsKafkaClient should not use

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

2017-06-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16063956#comment-16063956 ] Matthias J. Sax commented on KAFKA-4750: I think [~damianguy] or [~enothereska] can comment best

[jira] [Resolved] (KAFKA-5145) Remove task close() call from closeNonAssignedSuspendedTasks method

2017-06-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5145. Resolution: Duplicate > Remove task close() call from closeNonAssignedSuspendedTasks method

[jira] [Commented] (KAFKA-5145) Remove task close() call from closeNonAssignedSuspendedTasks method

2017-06-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062424#comment-16062424 ] Matthias J. Sax commented on KAFKA-5145: [~mingleizhang] Thanks for starting to contribute to

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

2017-06-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062423#comment-16062423 ] Matthias J. Sax commented on KAFKA-4750: Sounds good to me. > KeyValueIterator returns null

[jira] [Created] (KAFKA-5474) Streams StandbyTask should no checkpoint on commit if EOS is enabled

2017-06-19 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5474: -- Summary: Streams StandbyTask should no checkpoint on commit if EOS is enabled Key: KAFKA-5474 URL: https://issues.apache.org/jira/browse/KAFKA-5474 Project:

[jira] [Commented] (KAFKA-4857) Use AdminClient in Kafka Streams

2017-06-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16054904#comment-16054904 ] Matthias J. Sax commented on KAFKA-4857: Doing the KIP is part of the JIRA, so it's your call to

[jira] [Commented] (KAFKA-4437) Incremental Batch Processing for Kafka Streams

2017-06-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16054906#comment-16054906 ] Matthias J. Sax commented on KAFKA-4437: Thanks [~avi_parkassist]. Updated :) > Incremental Batch

[jira] [Commented] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2017-06-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059527#comment-16059527 ] Matthias J. Sax commented on KAFKA-5488: You can always start a discussion on the mailing list.

[jira] [Commented] (KAFKA-4857) Use AdminClient in Kafka Streams

2017-06-21 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057842#comment-16057842 ] Matthias J. Sax commented on KAFKA-4857: I meant was Ismael said. This Jira as intended to add a

[jira] [Created] (KAFKA-5464) StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG

2017-06-16 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5464: -- Summary: StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG Key: KAFKA-5464 URL: https://issues.apache.org/jira/browse/KAFKA-5464 Project: Kafka

[jira] [Created] (KAFKA-5456) Producer fails with NPE if record is larger than batch size

2017-06-15 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5456: -- Summary: Producer fails with NPE if record is larger than batch size Key: KAFKA-5456 URL: https://issues.apache.org/jira/browse/KAFKA-5456 Project: Kafka

[jira] [Updated] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

2017-06-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5167: --- Affects Version/s: 0.11.0.0 > streams task gets stuck after re-balance due to LockException >

[jira] [Commented] (KAFKA-5882) NullPointerException in ConsumerCoordinator

2017-09-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165085#comment-16165085 ] Matthias J. Sax commented on KAFKA-5882: I did have a look into the code, and don't understand how

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

2017-09-14 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166549#comment-16166549 ] Matthias J. Sax commented on KAFKA-5882: We actually do have system test for broker bounces. Thus,

[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream

2017-09-15 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16168170#comment-16168170 ] Matthias J. Sax commented on KAFKA-5765: Sure. If you need any help with the KIP, let us know.

[jira] [Updated] (KAFKA-5916) Upgrade rocksdb dependency to 5.7.3

2017-09-16 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5916: --- Component/s: streams > Upgrade rocksdb dependency to 5.7.3 >

[jira] [Updated] (KAFKA-5916) Upgrade rocksdb dependency to 5.7.3

2017-09-16 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5916: --- Affects Version/s: 0.11.0.0 > Upgrade rocksdb dependency to 5.7.3 >

[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream

2017-09-16 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16169063#comment-16169063 ] Matthias J. Sax commented on KAFKA-5765: [~Yohan123] Thanks for the patch. We do use Github to

  1   2   3   4   5   6   7   8   9   10   >