[
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
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
[
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
[
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
>
[
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
[
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://
[
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()
> ---
[
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
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
[
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
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
[
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
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
13 matches
Mail list logo