[
https://issues.apache.org/jira/browse/KAFKA-2551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-2551:
---
Assignee: Manikumar Reddy (was: jin xing)
Fix Version/s: 0.10.0.0
GitHub user omkred
Jiangjie Qin created KAFKA-3388:
---
Summary: Producer should only timeout a batch in the accumulator
when metadata is missing.
Key: KAFKA-3388
URL: https://issues.apache.org/jira/browse/KAFKA-3388
Project
[
https://issues.apache.org/jira/browse/KAFKA-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192034#comment-15192034
]
Ken Gidley commented on KAFKA-2359:
---
How about this use case:
I want to reprocess all
Hi All,
While working with KStream/KStreamImp I discovered that there does not seem
to be any way to connect the results of the KStream.process method with a
sink node.
I'd like to propose an addition to the API a "processTo" method.
I've looked at and used the "transform", "reduceByKey" and "ag
GitHub user omkreddy opened a pull request:
https://github.com/apache/kafka/pull/1054
KAFKA-2551: Update Unclean leader election docs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/omkreddy/kafka KAFKA-2551
Alternatively you ca
Good summary!
Some comments inline:
2016-03-11 22:59 GMT+01:00 Ashish Singh :
> Sounds like we are mostly in agreement. Following are the key points.
>
>1. Every time a protocol version changes, for any request/response,
>broker version, ApiVersion, will be bumped up.
>
Maybe clarify t
