[GitHub] kafka pull request #1686: KAFKA-4002: task.open() should be invoked in case ...

2016-07-29 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1686

KAFKA-4002: task.open() should be invoked in case that 0 partitions is 
assigned to task



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka open-partition

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1686.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1686


commit 1575cacb89c549544a0b02a7108ee5e069264784
Author: Liquan Pei 
Date:   2016-07-29T23:13:49Z

Call task.open() with empty partitions




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request #1574: KAFKA-3920: Add Schema source connector to Kafka C...

2016-06-29 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1574

KAFKA-3920: Add Schema source connector to Kafka Connect



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka schema-source

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1574.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1574


commit dd557b5dde7387b50a37ea91c3b92efe5b500852
Author: Liquan Pei 
Date:   2016-06-30T00:04:09Z

Add schema source connector




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request #1502: MINOR: Clarify the at least once delivery with aut...

2016-06-13 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1502

MINOR: Clarify the at least once delivery with auto commit enabled.



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka fetcher-comments

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1502.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1502






---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request #1475: MINOR: Add comment for round robin partitioner wit...

2016-06-06 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1475

MINOR: Add comment for round robin partitioner with different subscriptions



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka roundrobin-comment

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1475.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1475


commit 6be7c2380b2a4fb689dcfb42c6374fc4b9c528d4
Author: Liquan Pei 
Date:   2016-06-06T23:51:26Z

Add comment for round robin partitioner with different subscriptions




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: MINOR: Remove synchronized as the tasks are ex...

2016-05-27 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1441

MINOR: Remove synchronized as the tasks are executed sequentially



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka remove-synchronized

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1441.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1441


commit 02f229bbef4a7ce535bf2f70bcf72e6ffeeb6642
Author: Liquan Pei 
Date:   2016-05-27T21:33:13Z

Remove synchronized as the tasks are executed sequentially




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: MINOR: Catch Throwable in CommitSourceTask()

2016-05-18 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1402

MINOR: Catch Throwable in CommitSourceTask()



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka source-task-commit-record

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1402.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1402


commit cf0eb5028e3d7733fd1ec84ca3725d232c07ffc1
Author: Liquan Pei 
Date:   2016-05-19T00:34:39Z

Catch Throwable in CommitSourceTask()




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3421: Connect developer guide update and...

2016-05-11 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1366

KAFKA-3421: Connect developer guide update and several fixes

This is a follow up of KAKFA-3421 to update the connect developer guide to 
include the configuration validation. Also includes a couple of minor fixes.  

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka connect-dev-doc

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1366.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1366


commit 4d62ca73296531dc0b8c5962d18e9b5cf3201b12
Author: Liquan Pei 
Date:   2016-05-11T07:04:03Z

Add configuration validation to developer guide




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: MINOR: Add quotes to variables in kafka-run-cl...

2016-05-10 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1364

MINOR: Add quotes to variables in kafka-run-class.sh



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka add-quote-classpath

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1364.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1364


commit 7eb40b7a5366f31306c08e329e9bbaf688020d2b
Author: Liquan Pei 
Date:   2016-05-10T22:44:28Z

Add quotes to variables in kafka-run-class.sh




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: Avoid to pass null to UnmodifiableMap

2016-05-10 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1360

Avoid to pass null to UnmodifiableMap



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka avoid-to-pass-null

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1360.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1360






---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-2479: Transient exception

2016-05-09 Thread Ishiihara
Github user Ishiihara closed the pull request at:

https://github.com/apache/kafka/pull/279


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: MINOR: Should return ConfigDef in SourceConnec...

2016-05-09 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1356

MINOR: Should return ConfigDef in SourceConnectorConfig and 
SinkConnectorConfig



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka bug-fix-validate

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1356.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1356


commit 38cc2a031a010b104abc54261fec0f3b0f2f388c
Author: Liquan Pei 
Date:   2016-05-09T23:03:48Z

Bug fix




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: MINOR: Move connect.start() to try catch block

2016-05-08 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1347

MINOR: Move connect.start() to try catch block



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka connect-standalone

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1347.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1347


commit fb03779652e77784077c6fa35904cd3269228422
Author: Liquan Pei 
Date:   2016-05-09T05:00:29Z

Move connect.start() to try catch block




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: MINOR: Add virtual env to Kafka system test RE...

2016-05-08 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1346

MINOR: Add virtual env to Kafka system test README.md



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka add-venv

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1346.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1346


commit fe9478169343c66b41b20cd8fd8ce0667909529a
Author: Liquan Pei 
Date:   2016-05-09T04:54:36Z

Add virtual env in Kafka system test README.md




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: MINOR: Cleanup Admin Package

2016-05-07 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1342

MINOR: Cleanup Admin Package



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka clean-admin-package

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1342.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1342


commit 0b11c453717dbd095025f289931ac3352f03bce6
Author: Liquan Pei 
Date:   2016-05-04T17:00:13Z

WIP




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3673: Connect tests don't handle concurr...

2016-05-06 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1340

KAFKA-3673: Connect tests don't handle concurrent config changes



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka connect-test-failure

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1340.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1340


commit 6856f3457702d7855467fbbf6a92228928a8ce9a
Author: Liquan Pei 
Date:   2016-05-07T03:54:59Z

Address Connect test failure




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA 3671: Move topics to SinkConnectorConfig

2016-05-06 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1335

KAFKA 3671: Move topics to SinkConnectorConfig



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka sink-connector-config

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1335.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1335


commit 4dce2637af670a6ed67b3c62d7dea9b65a2b6304
Author: Liquan Pei 
Date:   2016-05-06T20:46:16Z

Move topics to SinkConnectorConfig




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3587: Fix fake large log segment in log ...

2016-05-05 Thread Ishiihara
Github user Ishiihara closed the pull request at:

https://github.com/apache/kafka/pull/1328


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: WIP: Fix fake large log segment in log cleaner

2016-05-05 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1328

WIP: Fix fake large log segment in log cleaner



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka kafka-3587

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1328.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1328


commit 098d8782777ec050aa1f5a5eebf183e8b01e9bff
Author: Liquan Pei 
Date:   2016-05-05T22:34:19Z

Fix fake large log segment in log cleaner




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA 3656: Remove logging outstanding message...

2016-05-04 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1319

KAFKA 3656: Remove logging outstanding messages when producer flush fails 



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka kafka-3656

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1319.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1319


commit 77af8cf2a7fbb0ecb58b63715ee1926655d96103
Author: Liquan Pei 
Date:   2016-05-04T17:08:37Z

Removing logging outstanding messages




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3654: Config validation should validate ...

2016-05-03 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1313

KAFKA-3654: Config validation should validate both common and connector 
specific configurations



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka config-short-circuit

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1313.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1313






---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: MINOR: Clean up of Kafka Consumer

2016-05-02 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1306

MINOR: Clean up of Kafka Consumer



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka minor-consumer-cleanup

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1306.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1306


commit eb393dd4d5783fe57137c0144f54804f5ae1e61e
Author: Liquan Pei 
Date:   2016-05-03T06:32:16Z

Minor clean up of Kafka Consumer




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3527: Consumer commitAsync should not ex...

2016-04-29 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1300

KAFKA-3527: Consumer commitAsync should not expose internal exceptions



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka kafka-3527

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1300.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1300


commit cb99c77ce01e0104f58189f00470081b01f46e50
Author: Liquan Pei 
Date:   2016-04-30T06:52:44Z

Convert internal exceptions to CommitFailedException and 
CommitFailedRetriableException




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3578: Allow cross origin HTTP requests o...

2016-04-28 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1288

KAFKA-3578: Allow cross origin HTTP requests on all HTTP methods



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka kip-56

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1288.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1288


commit 9388198b492656265bcff494401af73779fe446a
Author: Liquan Pei 
Date:   2016-04-28T23:54:15Z

Allow specifying allowed cross origin methods

commit 9ab79910162708713c60d42e6a09e5ed6260dd6d
Author: Liquan Pei 
Date:   2016-04-29T01:22:37Z

Add unit test for CORS allow methods




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: MINOR: Remove some warning

2016-04-27 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1280

MINOR: Remove some warning

@ijuma @junrao Can you take a look?

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka minor-warning-fix

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1280.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1280


commit 7c8d13402c73f27645b0ec2144422d9f0b8aa23b
Author: Liquan Pei 
Date:   2016-04-28T06:16:54Z

Remove some warning




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka-site pull request: Add Ismael to committers page

2016-04-26 Thread Ishiihara
Github user Ishiihara commented on the pull request:

https://github.com/apache/kafka-site/pull/11#issuecomment-214653285
  
LGTM


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3615: Exclude test jars in kafka-run-cla...

2016-04-23 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1263

KAFKA-3615: Exclude test jars in kafka-run-class.sh

@granders @hachikuji Can you take a look when you have time? Appreciate 
your time to review. 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka classpath-no-test-jar

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1263.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1263


commit 9bbb473966409fa515965ac91007ab03a1d5446e
Author: Liquan Pei 
Date:   2016-04-24T05:45:58Z

Exclude test jars in kafka-run-class.sh




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3611: Remove warnings when using reflect...

2016-04-22 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1259

KAFKA-3611: Remove warnings when using reflections

@ewencp @granders Can you take a look? Thanks!

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka fix-warning

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1259.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1259


commit 3319c946c4e217600ad455adf73362e83055cdd7
Author: Liquan Pei 
Date:   2016-04-23T04:45:05Z

Remove warnings when using reflections




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: Traverse CLASSPATH during herder start

2016-04-21 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1252

Traverse CLASSPATH during herder start

@ewencp Can you take a quick look?

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka pre-list-connectors

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1252.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1252


commit 4b4a425a8f4042f04ca0f83142aff31cdea882d7
Author: Liquan Pei 
Date:   2016-04-21T23:42:34Z

Traverse CLASSPATH during herder start




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3459: Returning zero task configurations...

2016-04-20 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1248

KAFKA-3459: Returning zero task configurations from a connector does not 
properly clean up existing tasks

@hachikuji @ewencp Can you take a look when you have time?

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka kafka-3459

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1248.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1248


commit e91c6032464e49759ab9f753ba6afe1181944770
Author: Liquan Pei 
Date:   2016-04-21T00:51:22Z

Handle zero task




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: Minor comment fix

2016-04-20 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1243

Minor comment fix

@ewencp 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka docs

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1243.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1243


commit 02784174943e2327a00e785534c2e820fc4c8d03
Author: Liquan Pei 
Date:   2016-04-20T19:00:32Z

Minor comment fix




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3582: Remove references to Copcyat from ...

2016-04-18 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1236

KAFKA-3582: Remove references to Copcyat from Kafka Connect property files  
@junrao



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka minor-fix

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1236.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1236


commit 219053ec2cdeaa3bbc987b2633b48e00835d46e5
Author: Liquan Pei 
Date:   2016-04-19T00:40:34Z

Minor fix




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA 3421: Update docs with new connector fea...

2016-04-15 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1227

KAFKA 3421: Update docs with new connector features

@ewencp @gwenshap Docs. I also tried to clean up some typos. However, it 
seems that the we don't have two words without space in between in the source 
yet they showed up as no space in between in the generated doc. 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka config-doc

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1227.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1227


commit c3c1daa92084e1cb26b2677f3cd6bff474ec27bd
Author: Liquan Pei 
Date:   2016-04-15T02:23:32Z

Clean up existing doc

commit 7708908b0a4852739e67fd169bd3199e23063f3d
Author: Liquan Pei 
Date:   2016-04-15T17:00:20Z

Add docs for new APIs




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3526: Return string instead of object in...

2016-04-07 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1200

KAFKA-3526: Return string instead of object in ConfigKeyInfo and 
ConfigValueInfo



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka config-string

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1200.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1200


commit 0a49d1df772b5810004c2c826a7dfb075d17db8b
Author: Liquan Pei 
Date:   2016-04-07T22:19:53Z

Return string instead of object in ConfigKeyInfo and ConfigValueInfo




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3520: Add system tests for REST APIs of ...

2016-04-06 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1195

KAFKA-3520: Add system tests for REST APIs of list connector plugins and 
config validation

@ewen @granders Ready for review. 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka system-test

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1195.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1195


commit f5fb2911c0dc5353d360c9df75ab3cfb44a2ab67
Author: Liquan Pei 
Date:   2016-04-06T21:50:38Z

Add system tests for REST APIs of list connector plugins and config 
validation




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: [Minor]: Clean up of SourceTaskOffsetCommiter

2016-03-31 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1170

[Minor]: Clean up of SourceTaskOffsetCommiter



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka minor-cleanup

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1170.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1170


commit 90d868bb383c62f732e3a68d7ed2eb98dcf39dbd
Author: Liquan Pei 
Date:   2016-03-31T23:21:29Z

Minor clean up of SourceTaskOffsetCommiter




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-3462: Allow SinkTasks to disable consume...

2016-03-24 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1139

KAFKA-3462: Allow SinkTasks to disable consumer offset commit



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka disable-offset-commit

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1139.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1139


commit 546877ddbb0acfa079b9322becbb2dbff21c56d7
Author: Liquan Pei 
Date:   2016-03-25T00:29:24Z

Allow SinkTasks to disable consumer offset commit




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: [KAFKA-3316]: Add REST API for listing connect...

2016-03-19 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1090

[KAFKA-3316]: Add REST API for listing connector plugins



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka kafka-3316

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1090.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1090


commit 2071b6223532279be05928965112a99782675a20
Author: Liquan Pei 
Date:   2016-03-16T22:09:32Z

add list connector plugins




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: [MINOR] cleanup

2016-03-14 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/1063

[MINOR] cleanup

@guozhangwang Very minor cleanup. 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka minor-cleanup

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/1063.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1063


commit 2131b2a9069de38906a1c25f1deec9b5b7e8867b
Author: Liquan Pei 
Date:   2016-03-14T21:48:55Z

minor cleanup




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: Add REST and Connector API to expose connector...

2016-02-24 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/964

Add REST and Connector API to expose connector configuration



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka expose-connector-config

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/964.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #964


commit d12c248c6f136c9f124104085c326e83f67bfd9a
Author: Liquan Pei 
Date:   2016-02-23T01:19:36Z

Add REST and Connector API to expose connector configuration




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA 2480 Add backoff timeout and support rew...

2015-10-20 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/340

KAFKA 2480 Add backoff timeout and support rewinds



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka backoff

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/340.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #340


commit d7fa3cc3feffec8349ce3ec08d0b70a242de632e
Author: Liquan Pei 
Date:   2015-10-21T01:00:26Z

Add backoff timeout and support rewinds




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: KAFKA-2484: Add schema projection utilities

2015-10-13 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/307

KAFKA-2484: Add schema projection utilities

This PR adds schema projection utilities to copycat. 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/Ishiihara/kafka schema-projection

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/307.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #307


commit 9747208fead30dcaed5295f674650b61cce25977
Author: Liquan Pei 
Date:   2015-10-14T01:16:32Z

Add schema projection utilities




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: Transient exception

2015-10-05 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/279

Transient exception

Transient exception handling.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/confluentinc/kafka transient-exception

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/279.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #279


commit c97df6dc18f7068866132a9237e8242286bab7c1
Author: Ewen Cheslack-Postava 
Date:   2015-09-28T00:59:30Z

KAFKA-2482: Allow sink tasks to get their current assignment, as well as 
pause and resume topic partitions.

commit 569d7b8ee2469f9427e002076d9e9b5af64aaf3b
Author: Ewen Cheslack-Postava 
Date:   2015-09-28T17:42:47Z

Merge branch 'trunk' of http://git-wip-us.apache.org/repos/asf/kafka into 
kafka-2482-sink-tasks-pause-consumption

commit 1451a2f2a00072c849ba4309952f0e0132a65d89
Author: Liquan Pei 
Date:   2015-10-01T22:20:33Z

Merge branch 'kafka-2482-sink-tasks-pause-consumption' of 
https://github.com/ewencp/kafka into periodic-put

commit 68b87011ae77126aa116bb74e4bc0cf90549219b
Author: Liquan Pei 
Date:   2015-10-05T21:40:33Z

Add transient exception handling




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: Should stop offset backing store in Copycat Wo...

2015-09-22 Thread Ishiihara
Github user Ishiihara closed the pull request at:

https://github.com/apache/kafka/pull/232


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] kafka pull request: Should stop offset backing store in Worker's s...

2015-09-22 Thread Ishiihara
GitHub user Ishiihara opened a pull request:

https://github.com/apache/kafka/pull/232

Should stop offset backing store in Worker's stop method



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/confluentinc/kafka bug-fix

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/232.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #232


commit 96cab04040bd74afbcf0011664be1c2348972c5e
Author: Liquan Pei 
Date:   2015-09-23T00:15:13Z

Should stop offset backing store in Worker's stop method




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---