[GitHub] kafka pull request #2110: KAFKA-4387: Fix KafkaConsumer not responding corre...

2016-11-07 Thread srdo
GitHub user srdo opened a pull request: https://github.com/apache/kafka/pull/2110 KAFKA-4387: Fix KafkaConsumer not responding correctly to interrupts,… ... throw InterruptException from blocking methods when interrupted See https://issues.apache.org/jira/browse/KAFKA

[GitHub] kafka pull request #2100: KAFKA-4375: Reset thread interrupted state in a fe...

2016-11-03 Thread srdo
GitHub user srdo opened a pull request: https://github.com/apache/kafka/pull/2100 KAFKA-4375: Reset thread interrupted state in a few places where Inte… …rruptedException is caught in a thread Kafka didn't start. See https://issues.apache.org/jira/browse/KAFKA-4375 You

[GitHub] kafka pull request #2093: MINOR: Add description of how consumer wakeup acts...

2016-11-02 Thread srdo
GitHub user srdo opened a pull request: https://github.com/apache/kafka/pull/2093 MINOR: Add description of how consumer wakeup acts if no threads are awakened I think the Javadoc should describe what happens if wakeup is called and no other thread is currently blocking. This may

[GitHub] kafka pull request: MINOR: Fix zk path in KafkaHealthCheck comment

2016-04-04 Thread srdo
GitHub user srdo opened a pull request: https://github.com/apache/kafka/pull/1182 MINOR: Fix zk path in KafkaHealthCheck comment You can merge this pull request into a Git repository by running: $ git pull https://github.com/srdo/kafka comment-fix Alternatively you can

[GitHub] kafka pull request: KAFKA-725: Change behavior of Log/LogSegment w...

2016-04-03 Thread srdo
Github user srdo closed the pull request at: https://github.com/apache/kafka/pull/1178 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] kafka pull request: KAFKA-725: Change behavior of Log/LogSegment w...

2016-04-02 Thread srdo
GitHub user srdo opened a pull request: https://github.com/apache/kafka/pull/1178 KAFKA-725: Change behavior of Log/LogSegment when attempting read on an offset that's above high watermark. This should make Log.read act the same when startOffset is larger than maxOffset