[GitHub] kafka pull request #3942: KAFKA-5957: Prevent second deallocate if response ...

2017-09-21 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3942 KAFKA-5957: Prevent second deallocate if response for aborted batch returns You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka pull request #3944: KAFKA-5960 [WIP]; Fix regression in produce versio...

2017-09-22 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3944 KAFKA-5960 [WIP]; Fix regression in produce version selection on old brokers You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka pull request #3976: MINOR: Follow-up cleanup of KAFKA-5960

2017-09-27 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3976 MINOR: Follow-up cleanup of KAFKA-5960 You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka version-fix-followup Alternatively

[GitHub] kafka pull request #4047: MINOR: Factor out some common group/transactional ...

2017-10-09 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/4047 MINOR: Factor out some common group/transactional fields in request objects You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka pull request #4076: MINOR: A few javadoc fixes

2017-10-16 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/4076 MINOR: A few javadoc fixes You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka javadoc-fixes Alternatively you can review and

[GitHub] kafka pull request #4141: KAFKA-6134: Read partition reassignment lazily on ...

2017-10-26 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/4141 KAFKA-6134: Read partition reassignment lazily on event handling This patch prevents an O(n^2) increase in memory utilization during partition reassignment. Instead of storing the reassigned

[GitHub] kafka pull request #4141: KAFKA-6134: Read partition reassignment lazily on ...

2017-10-26 Thread hachikuji
Github user hachikuji closed the pull request at: https://github.com/apache/kafka/pull/4141 ---

[GitHub] kafka pull request #4147: MINOR: Fix inconsistency in StopReplica/LeaderAndI...

2017-10-27 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/4147 MINOR: Fix inconsistency in StopReplica/LeaderAndIsr error counts You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka fix-error

[GitHub] kafka pull request #4256: KAFKA-6328: Fix 1.0.0 upgrade instructions relatin...

2017-11-22 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/4256 KAFKA-6328: Fix 1.0.0 upgrade instructions relating to the message format version The upgrade instructions concerning the message format versions did not account for upgrades from versions prior

[GitHub] kafka pull request #4276: KAFKA-6260: Ensure selection keys are removed from...

2017-11-29 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/4276 KAFKA-6260: Ensure selection keys are removed from all collections on socket close When a socket is closed, we must remove corresponding selection keys from internal collections. This fixes an

[GitHub] kafka pull request #4280: KAFKA-6289: NetworkClient should not expose failed...

2017-11-30 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/4280 KAFKA-6289: NetworkClient should not expose failed internal ApiVersions requests The NetworkClient internally ApiVersion requests to each broker following connection establishment. If this

[GitHub] kafka pull request #4285: KAFKA-6296: Increase jitter to fix transient failu...

2017-12-01 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/4285 KAFKA-6296: Increase jitter to fix transient failure in NetworkClientTest.testConnectionDelayDisconnected ### Committer Checklist (excluded from commit message) - [ ] Verify design and

[GitHub] kafka pull request #4287: KAFKA-6118: Fix transient failure testTwoConsumers...

2017-12-01 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/4287 KAFKA-6118: Fix transient failure testTwoConsumersWithDifferentSaslCredentials It's rare, but it can happen that the initial FindCoordinator request returns before the first Metadata re

[GitHub] kafka pull request #4349: KAFKA-6366 [WIP]: Fix stack overflow in consumer d...

2017-12-20 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/4349 KAFKA-6366 [WIP]: Fix stack overflow in consumer due to fast offset commits during coordinator disconnect When the coordinator is marked unknown, we explicitly disconnect its connection and

[GitHub] kafka-site pull request #60: Update delivery semantics section for KIP-98

2017-06-09 Thread hachikuji
Github user hachikuji commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/60#discussion_r121249508 --- Diff: 0110/design.html --- @@ -261,15 +262,23 @@ It can read the messages, process the messages, and finally save its position. In this

[GitHub] kafka-site pull request #60: Update delivery semantics section for KIP-98

2017-06-09 Thread hachikuji
Github user hachikuji commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/60#discussion_r121249550 --- Diff: 0110/design.html --- @@ -261,15 +262,23 @@ It can read the messages, process the messages, and finally save its position. In this

[GitHub] kafka pull request #3297: KAFKA-5427: Transactional producer should allow Fi...

2017-06-10 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3297 KAFKA-5427: Transactional producer should allow FindCoordinator in error state You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji

[GitHub] kafka pull request #3298: KAFKA-5428: Transactional producer should only abo...

2017-06-11 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3298 KAFKA-5428: Transactional producer should only abort batches in fatal error state You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji

[GitHub] kafka pull request #3300: KAFKA-5429: Ignore produce response if batch was p...

2017-06-11 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3300 KAFKA-5429: Ignore produce response if batch was previously aborted You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA

[GitHub] kafka pull request #3306: KAFKA-5435: Ensure producer snapshot retained afte...

2017-06-12 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3306 KAFKA-5435: Ensure producer snapshot retained after truncation You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-5435

[GitHub] kafka pull request #3318: HOTFIX: Fix invalid long format conversion in requ...

2017-06-13 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3318 HOTFIX: Fix invalid long format conversion in request logger message You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka hotfix

[GitHub] kafka pull request #3331: KAFKA-5443: Consumer should use last offset from b...

2017-06-13 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3331 KAFKA-5443: Consumer should use last offset from batch to set next fetch offset You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji

[GitHub] kafka pull request #3340: MINOR: Add random aborts to system test transactio...

2017-06-14 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3340 MINOR: Add random aborts to system test transactional copier service You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka add

[GitHub] kafka-site issue #60: Update delivery semantics section for KIP-98

2017-06-14 Thread hachikuji
Github user hachikuji commented on the issue: https://github.com/apache/kafka-site/pull/60 @guozhangwang @ijuma @apurvam Pushed a couple changes based on the review. Please take another look. --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] kafka pull request #3348: MINOR: Fix unsafe access to incomplete collection ...

2017-06-14 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3348 MINOR: Fix unsafe access to incomplete collection in RecordAccumulator You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka fix

[GitHub] kafka pull request #3356: KAFKA-5456: Ensure producer handles old format lar...

2017-06-15 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3356 KAFKA-5456: Ensure producer handles old format large compressed messages You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka pull request #3306: KAFKA-5435: Ensure producer snapshot retained afte...

2017-06-16 Thread hachikuji
Github user hachikuji closed the pull request at: https://github.com/apache/kafka/pull/3306 --- 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 is

[GitHub] kafka pull request #3361: KAFKA-5435: Improve producer state loading after f...

2017-06-16 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3361 KAFKA-5435: Improve producer state loading after failure You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-5435-ALT

[GitHub] kafka pull request #3363: MINOR: Some small cleanups/improvements to KAFKA-5...

2017-06-16 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3363 MINOR: Some small cleanups/improvements to KAFKA-5031 You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-5031-FOLLOWUP

[GitHub] kafka pull request #3373: MINOR: Detail message/batch size implications for ...

2017-06-19 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3373 MINOR: Detail message/batch size implications for conversion between old and new formats You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka-site pull request #60: Update delivery semantics section for KIP-98

2017-06-19 Thread hachikuji
Github user hachikuji commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/60#discussion_r122825810 --- Diff: 0110/design.html --- @@ -264,21 +264,22 @@ messages have a primary key and so the updates are idempotent (receiving the same message

[GitHub] kafka-site pull request #60: Update delivery semantics section for KIP-98

2017-06-19 Thread hachikuji
Github user hachikuji commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/60#discussion_r122826323 --- Diff: 0110/design.html --- @@ -264,21 +264,22 @@ messages have a primary key and so the updates are idempotent (receiving the same message

[GitHub] kafka pull request #3376: MINOR: MemoryRecordsBuilder.sizeInBytes should con...

2017-06-19 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3376 MINOR: MemoryRecordsBuilder.sizeInBytes should consider initial position You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka-site issue #60: Update delivery semantics section for KIP-98

2017-06-20 Thread hachikuji
Github user hachikuji commented on the issue: https://github.com/apache/kafka-site/pull/60 I'm going to reopen this as a PR against kafka since that is where design.html is maintained. --- If your project is set up for it, you can reply to this email and have your reply appe

[GitHub] kafka-site pull request #60: Update delivery semantics section for KIP-98

2017-06-20 Thread hachikuji
Github user hachikuji closed the pull request at: https://github.com/apache/kafka-site/pull/60 --- 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 #3388: KAFKA-5021: Update delivery semantics documentatio...

2017-06-20 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3388 KAFKA-5021: Update delivery semantics documentation for EoS (KIP-98) You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA

[GitHub] kafka pull request #3406: KAFKA-5490: Retain empty batch for last sequence o...

2017-06-21 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3406 KAFKA-5490: Retain empty batch for last sequence of each producer You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-5490

[GitHub] kafka pull request #3426: MINOR: Fix race condition in KafkaConsumer close

2017-06-23 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3426 MINOR: Fix race condition in KafkaConsumer close We intended to make `KafkaConsumer.close()` idempotent, but due to the fact that the `closed` variable is checked without a lock prior to

[GitHub] kafka pull request #3456: KAFKA-5522: ListOffsets should bound timestamp sea...

2017-06-28 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3456 KAFKA-5522: ListOffsets should bound timestamp search by LSO in read_committed You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji

[GitHub] kafka pull request #3457: MINOR: Rename baseTimestamp to firstTimestamp to c...

2017-06-28 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3457 MINOR: Rename baseTimestamp to firstTimestamp to clarify usage You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka rename-base

[GitHub] kafka pull request #3558: MINOR: Safer handling of requests prior to SASL au...

2017-07-20 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3558 MINOR: Safer handling of requests prior to SASL authentication This implements two improvements for request handling prior to SASL authentication: 1. Only parse request types that are

[GitHub] kafka pull request #3571: KAFKA-5611; AbstractCoordinator should handle wake...

2017-07-24 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3571 KAFKA-5611; AbstractCoordinator should handle wakeup raised from onJoinComplete You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji

[GitHub] kafka pull request #3575: KAFKA-5634; Do not allow segment deletion beyond h...

2017-07-25 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3575 KAFKA-5634; Do not allow segment deletion beyond high watermark You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-5634

[GitHub] kafka pull request #3612: MINOR: Remove legacy ControlledShutdown request/re...

2017-08-02 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3612 MINOR: Remove legacy ControlledShutdown request/response objects You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka remove-old

[GitHub] kafka pull request #3627: MINOR: Fix error response handler for controlled s...

2017-08-04 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3627 MINOR: Fix error response handler for controlled shutdown v0 You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka minor-fix

[GitHub] kafka pull request #3646: MINOR: Remove unneeded error handlers in deprecate...

2017-08-08 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3646 MINOR: Remove unneeded error handlers in deprecated request objects These handlers were previously used on the broker to handle uncaught exceptions, but now the broker users the new Java request

[GitHub] kafka pull request #3651: MINOR: Add missing deprecations on old request obj...

2017-08-09 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3651 MINOR: Add missing deprecations on old request objects You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka add-missing-request

[GitHub] kafka pull request #3665: HOTFIX: ConsoleConsumer using wrong old consumer c...

2017-08-14 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3665 HOTFIX: ConsoleConsumer using wrong old consumer config value for auto.offset.reset You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request #3666: KAFKA-5730: Consumer should invoke async commit ca...

2017-08-14 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3666 KAFKA-5730: Consumer should invoke async commit callback before sync commit returns You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request #3673: MINOR: Consolidate broker request/response handlin...

2017-08-15 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3673 MINOR: Consolidate broker request/response handling This patch contains a few small improvements to make request/response handling more consistent. Primarily it consolidates request/response

[GitHub] kafka pull request #3676: MINOR: Ensure consumer logging has clientId/groupI...

2017-08-16 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3676 MINOR: Ensure consumer logging has clientId/groupId context You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka log-consumer

[GitHub] kafka pull request #3688: KAFKA-5747: Producer snapshot loading should cover...

2017-08-17 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3688 KAFKA-5747: Producer snapshot loading should cover schema and other errors You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka pull request #3716: KAFKA-5342: Clarify fatal/abortable exceptions use...

2017-08-22 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3716 KAFKA-5342: Clarify fatal/abortable exceptions used in producer You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-5342

[GitHub] kafka-site pull request #72: Jason and Becket are PMC members

2017-08-29 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka-site/pull/72 Jason and Becket are PMC members You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka-site update-pmc-members Alternatively

[GitHub] kafka-site pull request #72: Jason and Becket are PMC members

2017-08-30 Thread hachikuji
Github user hachikuji closed the pull request at: https://github.com/apache/kafka-site/pull/72 --- 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 #3778: KAFKA-5822: Consistent log formatting of topic par...

2017-09-01 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3778 KAFKA-5822: Consistent log formatting of topic partitions You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-5822

[GitHub] kafka pull request #3795: KAFKA-5783: Add KafkaPrincipalBuilder with support...

2017-09-05 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3795 KAFKA-5783: Add KafkaPrincipalBuilder with support for SASL (KIP-189) You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA

[GitHub] kafka pull request #3813: MINOR: Move request/response schemas to the corres...

2017-09-07 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3813 MINOR: Move request/response schemas to the corresponding object representation This refactor achieves the following: 1. Breaks up the increasingly unmanageable `Protocol` class. 2

[GitHub] kafka pull request #3852: MINOR: Update TransactionManager to use LogContext

2017-09-13 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3852 MINOR: Update TransactionManager to use LogContext You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka minor-use-log-context-txn

[GitHub] kafka pull request #3863: MINOR: Use SecurityProtocol in AuthenticationConte...

2017-09-14 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3863 MINOR: Use SecurityProtocol in AuthenticationContext Since we removed the unused `TRACE` option from `SecurityProtocol`, it now seems safer to expose it from `AuthenticationContext`. Additionally

[GitHub] kafka pull request: KAFKA-2720 [WIP]: expire group metadata when a...

2016-05-24 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1427 KAFKA-2720 [WIP]: expire group metadata when all offsets have expired You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA

[GitHub] kafka pull request: HOTFIX: remove from inflightResponses on client disconne...

2016-05-31 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1452 HOTFIX: remove from inflightResponses on client disconnect to prevent memory leak You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji

[GitHub] kafka pull request: KAFKA-3773: Remove from inflightResponses on client disc...

2016-05-31 Thread hachikuji
GitHub user hachikuji reopened a pull request: https://github.com/apache/kafka/pull/1452 KAFKA-3773: Remove from inflightResponses on client disconnect to prevent memory leak You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request: KAFKA-3773: Remove from inflightResponses on client disc...

2016-05-31 Thread hachikuji
Github user hachikuji closed the pull request at: https://github.com/apache/kafka/pull/1452 --- 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 is

[GitHub] kafka pull request: KAFKA-3773: Remove from inflightResponses on client disc...

2016-05-31 Thread hachikuji
Github user hachikuji closed the pull request at: https://github.com/apache/kafka/pull/1452 --- 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 is

[GitHub] kafka pull request #1511: KAFKA-XXXX: WorkerSinkTask commit prior to rebalan...

2016-06-15 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1511 KAFKA-: WorkerSinkTask commit prior to rebalance should be retried on wakeup You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji

[GitHub] kafka pull request #1511: KAFKA-3850: WorkerSinkTask commit prior to rebalan...

2016-06-15 Thread hachikuji
GitHub user hachikuji reopened a pull request: https://github.com/apache/kafka/pull/1511 KAFKA-3850: WorkerSinkTask commit prior to rebalance should be retried on wakeup You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji

[GitHub] kafka pull request #1511: KAFKA-3850: WorkerSinkTask commit prior to rebalan...

2016-06-15 Thread hachikuji
Github user hachikuji closed the pull request at: https://github.com/apache/kafka/pull/1511 --- 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 is

[GitHub] kafka pull request #1513: MINOR: Follow-up from KAFKA-2720 with comment/styl...

2016-06-16 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1513 MINOR: Follow-up from KAFKA-2720 with comment/style fixes You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka followup-for-kafka

[GitHub] kafka pull request #1518: KAFKA-3632; remove fetcher metrics on shutdown and...

2016-06-17 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1518 KAFKA-3632; remove fetcher metrics on shutdown and leader migration You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka port

[GitHub] kafka pull request #1519: KAFKA-3863: System tests covering connector/task f...

2016-06-17 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1519 KAFKA-3863: System tests covering connector/task failure and restart You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA

[GitHub] kafka pull request #1518: KAFKA-3632; remove fetcher metrics on shutdown and...

2016-06-19 Thread hachikuji
Github user hachikuji closed the pull request at: https://github.com/apache/kafka/pull/1518 --- 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 is

[GitHub] kafka pull request #1531: KAFKA-3865: Fix transient failure in WorkerSourceT...

2016-06-20 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1531 KAFKA-3865: Fix transient failure in WorkerSourceTaskTest.testSlowTaskStart You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka pull request #1627: KAFKA-3888: send consumer heartbeats from a backgr...

2016-07-15 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1627 KAFKA-3888: send consumer heartbeats from a background thread (KIP-62) You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA

[GitHub] kafka pull request #1650: KAFKA-3782: Fix transient failure in connect distr...

2016-07-21 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1650 KAFKA-3782: Fix transient failure in connect distributed bounce test You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka pull request #1656: KAFKA-3977: Defer fetch parsing for space efficien...

2016-07-22 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1656 KAFKA-3977: Defer fetch parsing for space efficiency and to ensure exceptions are raised to the user You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] kafka pull request #1676: MINOR: Consumer should throw KafkaException on inv...

2016-07-28 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1676 MINOR: Consumer should throw KafkaException on invalid checksum You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka raise-kafka

[GitHub] kafka pull request #2140: KAFKA-4390: Replace MessageSet usage with client-s...

2016-11-15 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2140 KAFKA-4390: Replace MessageSet usage with client-side alternatives You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA4390

[GitHub] kafka pull request #2190: KAFKA-4469: Fix consumer performance regression fr...

2016-11-29 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2190 KAFKA-4469: Fix consumer performance regression from unneeded list copy You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA

[GitHub] kafka pull request #2195: KAFKA-3994: Fix deadlock in Watchers by calling tr...

2016-11-30 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2195 KAFKA-3994: Fix deadlock in Watchers by calling tryComplete without any locks You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji

[GitHub] kafka pull request #1738: KAFKA-3994: Fix deadlock in Watchers by calling tr...

2016-11-30 Thread hachikuji
Github user hachikuji closed the pull request at: https://github.com/apache/kafka/pull/1738 --- 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 is

[GitHub] kafka pull request #2202: MINOR: Improvements in group metadata cleanup and ...

2016-12-01 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2202 MINOR: Improvements in group metadata cleanup and test coverage You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka group

[GitHub] kafka pull request #2279: KAFKA-4166: Fix transient MM failure caused by slo...

2016-12-19 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2279 KAFKA-4166: Fix transient MM failure caused by slow old consumer shutdown You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka pull request #2282: MINOR: Support auto-incrementing offsets in Memory...

2016-12-20 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2282 MINOR: Support auto-incrementing offsets in MemoryRecordsBuilder You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka builder

[GitHub] kafka pull request #2596: MINOR: Ensure consumer calls poll() if requests ar...

2017-02-24 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2596 MINOR: Ensure consumer calls poll() if requests are outstanding You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka ensure-poll

[GitHub] kafka pull request #2614: KAFKA-4816: Message format changes for idempotent/...

2017-02-28 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2614 KAFKA-4816: Message format changes for idempotent/transactional producer You can merge this pull request into a Git repository by running: $ git pull https://github.com/confluentinc/kafka

[GitHub] kafka pull request #2646: MINOR: Rename RecordBatch to ProducerBatch to allo...

2017-03-06 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2646 MINOR: Rename RecordBatch to ProducerBatch to allow reuse in KIP-98 You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka rename

[GitHub] kafka pull request #2647: MINOR: Add varint serde utilities for new message ...

2017-03-06 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2647 MINOR: Add varint serde utilities for new message format You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka add-varint-serdes

[GitHub] kafka pull request #2656: MINOR: Use ConcurrentMap for ConsumerNetworkClient...

2017-03-08 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2656 MINOR: Use ConcurrentMap for ConsumerNetworkClient UnsentRequests You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka minor

[GitHub] kafka pull request #2736: HOTFIX: Fix unsafe dependence on class name in Ver...

2017-03-24 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2736 HOTFIX: Fix unsafe dependence on class name in VerifiableClientJava You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka hotfix

[GitHub] kafka pull request #2738: MINOR: Support streaming decompression of fetched ...

2017-03-25 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2738 MINOR: Support streaming decompression of fetched records for new format You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka pull request #2745: MINOR: Replication system tests should cover compr...

2017-03-27 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2745 MINOR: Replication system tests should cover compressed path You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka add-replication

[GitHub] kafka pull request #2762: MINOR: Ensure streaming iterator is closed by Fetc...

2017-03-29 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2762 MINOR: Ensure streaming iterator is closed by Fetcher You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka ensure-decompression

[GitHub] kafka pull request #2771: KAFKA-4689: Disable system tests for consumer hard...

2017-03-30 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2771 KAFKA-4689: Disable system tests for consumer hard failures See the JIRA for the full details. Essentially the test assertions depend on receiving reliable events from the consumer processes, but

[GitHub] kafka pull request #2866: MINOR: Improvements to PID snapshot management

2017-04-17 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2866 MINOR: Improvements to PID snapshot management You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka improve-snapshot-management

[GitHub] kafka pull request #2870: MINOR: Fix open file leak in log cleaner integrati...

2017-04-18 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2870 MINOR: Fix open file leak in log cleaner integration tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka fix-log-cleaner

[GitHub] kafka pull request #2881: MINOR: Remove redundant CRC validation for non-com...

2017-04-20 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2881 MINOR: Remove redundant CRC validation for non-compressed records in older message formats You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request #2892: KAFKA-5110: Check for errors when fetching the log...

2017-04-21 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2892 KAFKA-5110: Check for errors when fetching the log end offset in ConsumerGroupCommand You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request #2348: MINOR: Minor improvements in consumer close timeou...

2017-01-11 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2348 MINOR: Minor improvements in consumer close timeout handling You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka minor-cleanup

[GitHub] kafka pull request #2372: MINOR: Remove unneeded client used API lists

2017-01-13 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2372 MINOR: Remove unneeded client used API lists You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka minor-cleanup-used-apis

  1   2   3   4   >