[jira] [Commented] (KAFKA-5368) Kafka Streams skipped-records-rate sensor produces nonzero values when the timestamps are valid

2017-06-02 Thread Hamidreza Afzali (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16034367#comment-16034367 ] Hamidreza Afzali commented on KAFKA-5368: - *Problem:* Skipped records sensor is u

[jira] [Created] (KAFKA-5368) Kafka Streams skipped-records-rate sensor produces nonzero values when the timestamps are valid

2017-06-02 Thread Hamidreza Afzali (JIRA)
Hamidreza Afzali created KAFKA-5368: --- Summary: Kafka Streams skipped-records-rate sensor produces nonzero values when the timestamps are valid Key: KAFKA-5368 URL: https://issues.apache.org/jira/browse/KAFKA-536

[jira] [Resolved] (KAFKA-4408) KTable doesn't work with ProcessorTopologyTestDriver in Kafka 0.10.1.0

2017-03-06 Thread Hamidreza Afzali (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hamidreza Afzali resolved KAFKA-4408. - Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2629 https

[jira] [Work started] (KAFKA-4408) KTable doesn't work with ProcessorTopologyTestDriver in Kafka 0.10.1.0

2017-03-05 Thread Hamidreza Afzali (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4408 started by Hamidreza Afzali. --- > KTable doesn't work with ProcessorTopologyTestDriver in Kafka 0.10.1.0 >

[jira] [Assigned] (KAFKA-4408) KTable doesn't work with ProcessorTopologyTestDriver in Kafka 0.10.1.0

2017-03-05 Thread Hamidreza Afzali (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hamidreza Afzali reassigned KAFKA-4408: --- Assignee: Hamidreza Afzali > KTable doesn't work with ProcessorTopologyTestDriver in

[jira] [Commented] (KAFKA-4408) KTable doesn't work with ProcessorTopologyTestDriver in Kafka 0.10.1.0

2017-03-05 Thread Hamidreza Afzali (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896843#comment-15896843 ] Hamidreza Afzali commented on KAFKA-4408: - This should resolve the issue: https://

[jira] [Work started] (KAFKA-4828) ProcessorTopologyTestDriver does not work when using .through()

2017-03-04 Thread Hamidreza Afzali (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4828 started by Hamidreza Afzali. --- > ProcessorTopologyTestDriver does not work when using .through() > ---

[jira] [Commented] (KAFKA-4828) ProcessorTopologyTestDriver does not work when using .through()

2017-03-02 Thread Hamidreza Afzali (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15893105#comment-15893105 ] Hamidreza Afzali commented on KAFKA-4828: - There are two issues: - ProcessorTopolo

[jira] [Created] (KAFKA-4828) ProcessorTopologyTestDriver does not work when using .through()

2017-03-01 Thread Hamidreza Afzali (JIRA)
Hamidreza Afzali created KAFKA-4828: --- Summary: ProcessorTopologyTestDriver does not work when using .through() Key: KAFKA-4828 URL: https://issues.apache.org/jira/browse/KAFKA-4828 Project: Kafka

[jira] [Commented] (KAFKA-4789) ProcessorTopologyTestDriver does not forward extracted timestamps to internal topics

2017-02-28 Thread Hamidreza Afzali (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15888941#comment-15888941 ] Hamidreza Afzali commented on KAFKA-4789: - Thanks! > ProcessorTopologyTestDriver

[jira] [Created] (KAFKA-4789) ProcessorTopologyTestDriver does not forward extracted timestamps to internal topics

2017-02-23 Thread Hamidreza Afzali (JIRA)
Hamidreza Afzali created KAFKA-4789: --- Summary: ProcessorTopologyTestDriver does not forward extracted timestamps to internal topics Key: KAFKA-4789 URL: https://issues.apache.org/jira/browse/KAFKA-4789

[jira] [Updated] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result

2016-12-01 Thread Hamidreza Afzali (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hamidreza Afzali updated KAFKA-4461: Description: *Problem* When using ProcessorTopologyTestDriver in the latest Kafka 0.10.1, t

[jira] [Created] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result

2016-11-29 Thread Hamidreza Afzali (JIRA)
Hamidreza Afzali created KAFKA-4461: --- Summary: When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result Key: KAFKA-4461 URL: https://issues.apache.org/jira/brows