[jira] [Updated] (KAFKA-2551) Unclean leader election docs outdated

[ 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

[jira] [Created] (KAFKA-3388) Producer should only timeout a batch in the accumulator when metadata is missing.

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

[jira] [Commented] (KAFKA-2359) New consumer - partitions auto assigned only on poll

[ https://issues.apache.org/jira/browse/KAFKA-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15192034#comment-15192034 ] Ken Gidley commented on KAFKA-2359: --- How about this use case: I want to reprocess all the data in my

KStreams Proposal

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

[GitHub] kafka pull request: KAFKA-2551: Update Unclean leader election doc...

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

Re: [DISCUSS] KIP-35 - Retrieve protocol version

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