[GitHub] kafka pull request #2465: KAFKA-4710: Interpolate log4j's logging source int...

2017-03-03 Thread kawamuray
Github user kawamuray closed the pull request at: https://github.com/apache/kafka/pull/2465 --- 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 #2465: KAFKA-4710: Interpolate log4j's logging source int...

2017-01-30 Thread kawamuray
GitHub user kawamuray opened a pull request: https://github.com/apache/kafka/pull/2465 KAFKA-4710: Interpolate log4j's logging source interpretation to correct loation info of logs written through trait methods Issue: https://issues.apache.org/jira/browse/KAFKA-4710

[GitHub] kafka pull request #2352: KAFKA-4614 Forcefully unmap mmap of OffsetIndex to...

2017-01-12 Thread kawamuray
GitHub user kawamuray opened a pull request: https://github.com/apache/kafka/pull/2352 KAFKA-4614 Forcefully unmap mmap of OffsetIndex to prevent long GC pause Issue: https://issues.apache.org/jira/browse/KAFKA-4614 Fixes the problem that the broker threads suffered by long

[GitHub] kafka pull request #1816: KAFKA-4116: Handle 0.0.0.0 as a special case when ...

2016-09-02 Thread kawamuray
GitHub user kawamuray opened a pull request: https://github.com/apache/kafka/pull/1816 KAFKA-4116: Handle 0.0.0.0 as a special case when using advertised.listeners Issue: https://issues.apache.org/jira/browse/KAFKA-4116 You can merge this pull request into a Git repository

[GitHub] kafka pull request #1707: KAFKA-4024 KafkaProducer should not initialize met...

2016-08-06 Thread kawamuray
GitHub user kawamuray opened a pull request: https://github.com/apache/kafka/pull/1707 KAFKA-4024 KafkaProducer should not initialize metadata with current timestamp Issue: https://issues.apache.org/jira/browse/KAFKA-4024 Solves the problem that the first metadata update

[GitHub] kafka pull request #1606: KAFKA-3947: Add dumping current assignment capabil...

2016-07-15 Thread kawamuray
GitHub user kawamuray reopened a pull request: https://github.com/apache/kafka/pull/1606 KAFKA-3947: Add dumping current assignment capability to kafka-reassign-partitions.sh Issue: https://issues.apache.org/jira/browse/KAFKA-3947 You can merge this pull request into a Git

[GitHub] kafka pull request #1607: MINOR: Doc of 'retries' config should mention abou...

2016-07-15 Thread kawamuray
Github user kawamuray closed the pull request at: https://github.com/apache/kafka/pull/1607 --- 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 #1606: KAFKA-3947: Add dumping current assignment capabil...

2016-07-15 Thread kawamuray
Github user kawamuray closed the pull request at: https://github.com/apache/kafka/pull/1606 --- 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 #1607: MINOR: Doc of 'retries' config should mention abou...

2016-07-15 Thread kawamuray
GitHub user kawamuray reopened a pull request: https://github.com/apache/kafka/pull/1607 MINOR: Doc of 'retries' config should mention about max.in.flight.requests.per.connection to avoid confusion When I first read the doc of producer config `retries`, it was quite confusing

[GitHub] kafka pull request #1607: MINOR: Doc of 'retires' config should mention abou...

2016-07-11 Thread kawamuray
GitHub user kawamuray opened a pull request: https://github.com/apache/kafka/pull/1607 MINOR: Doc of 'retires' config should mention about max.in.flight.requests.per.connection to avoid confusion When I first read the doc of producer config `retries`, it was quite confusing

[GitHub] kafka pull request #1606: KAFKA-3947: Add dumping current assignment capabil...

2016-07-11 Thread kawamuray
GitHub user kawamuray opened a pull request: https://github.com/apache/kafka/pull/1606 KAFKA-3947: Add dumping current assignment capability to kafka-reassign-partitions.sh Issue: https://issues.apache.org/jira/browse/KAFKA-3947 You can merge this pull request into a Git

[GitHub] kafka pull request #1555: MINOR: Fix ambiguous log message in RecordCollecto...

2016-06-29 Thread kawamuray
GitHub user kawamuray reopened a pull request: https://github.com/apache/kafka/pull/1555 MINOR: Fix ambiguous log message in RecordCollector When producing fails in Kafka Streams, it gives an error like below: ``` Error sending record: null ``` by this line

[GitHub] kafka pull request #1555: MINOR: Fix ambiguous log message in RecordCollecto...

2016-06-29 Thread kawamuray
Github user kawamuray closed the pull request at: https://github.com/apache/kafka/pull/1555 --- 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 #1555: MINOR: Fix ambiguous log message in RecordCollecto...

2016-06-26 Thread kawamuray
GitHub user kawamuray opened a pull request: https://github.com/apache/kafka/pull/1555 MINOR: Fix ambiguous log message in RecordCollector When producing fails in Kafka Streams, it gives an error like below: ``` Error sending record: null ``` by this line

[GitHub] kafka pull request #1460: KAFKA-3775: Throttle maximum number of tasks assig...

2016-06-12 Thread kawamuray
Github user kawamuray closed the pull request at: https://github.com/apache/kafka/pull/1460 --- 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 #1460: KAFKA-3775: Throttle maximum number of tasks assig...

2016-06-02 Thread kawamuray
GitHub user kawamuray opened a pull request: https://github.com/apache/kafka/pull/1460 KAFKA-3775: Throttle maximum number of tasks assigned to a single KafkaStreams Issue: https://issues.apache.org/jira/browse/KAFKA-3775 POC. Discussion in progress. You can merge

[GitHub] kafka pull request: KAFKA-3642: Fix NPE from ProcessorStateManager...

2016-04-29 Thread kawamuray
GitHub user kawamuray opened a pull request: https://github.com/apache/kafka/pull/1289 KAFKA-3642: Fix NPE from ProcessorStateManager when the changelog topic not exists Issue: https://issues.apache.org/jira/browse/KAFKA-3642 You can merge this pull request into a Git repository

[GitHub] kafka pull request: KAFKA-3616: Make kafka producers/consumers inj...

2016-04-24 Thread kawamuray
GitHub user kawamuray opened a pull request: https://github.com/apache/kafka/pull/1264 KAFKA-3616: Make kafka producers/consumers injectable for KafkaStreams Ticket: https://issues.apache.org/jira/browse/KAFKA-3616 WIP. Just to show my mind. Will follow-up after positive

[GitHub] kafka pull request: KAFKA-3471: min.insync.replicas isn't respecte...

2016-03-30 Thread kawamuray
Github user kawamuray closed the pull request at: https://github.com/apache/kafka/pull/1146 --- 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-3471: min.insync.replicas isn't respecte...

2016-03-26 Thread kawamuray
GitHub user kawamuray opened a pull request: https://github.com/apache/kafka/pull/1146 KAFKA-3471: min.insync.replicas isn't respected when there's a delaying follower who still in ISR Ticket: https://issues.apache.org/jira/browse/KAFKA-3471 The number of followers which