[GitHub] kafka pull request #1820: MINOR: Add timeout to testRenegotiation.

2016-09-02 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

MINOR: Add timeout to testRenegotiation.



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

$ git pull https://github.com/SinghAsDev/kafka MinorTestRenogtiation

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

https://github.com/apache/kafka/pull/1820.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 #1820


commit 10ff174518d714e485488f962135505a5db7e0d4
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-09-02T18:39:57Z

MINOR: Add timeout to testRenegotiation.




---
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 #1772: MINOR: Update Kafka configuration documentation to...

2016-08-22 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

MINOR: Update Kafka configuration documentation to use kafka-configs.…

…sh, instead of deprecated kafka-topics.sh --alter

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

$ git pull https://github.com/SinghAsDev/kafka MinorKafkaConfigsDoc

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

https://github.com/apache/kafka/pull/1772.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 #1772


commit a8eb6a2e1420173bc129844b28fda7932d5f7d26
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-08-23T00:22:44Z

MINOR: Update Kafka configuration documentation to use kafka-configs.sh, 
instead of deprecated kafka-topics.sh --alter




---
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 #1770: WIP: KAFKA-2629: Enable getting passwords from an ...

2016-08-22 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

WIP: KAFKA-2629: Enable getting passwords from an executable rathe…

…r than passing plaintext password

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2629

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

https://github.com/apache/kafka/pull/1770.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 #1770


commit 025e27eda77292279b6b9629e7bb69dda2cef5dd
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-08-16T23:16:38Z

WIP: KAFKA-2629: Enable getting SSL password from an executable rather than 
passing plaintext password




---
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 #1749: KAFKA-4052: Allow passing properties file to Produ...

2016-08-16 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-4052: Allow passing properties file to ProducerPerformance



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-4052

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

https://github.com/apache/kafka/pull/1749.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 #1749


commit 4fee22a1489286a8146935f18f942fe405a71732
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-08-17T01:27:06Z

KAFKA-4052: Allow passing properties file to ProducerPerformance




---
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 #1609: Minor: Improve PartitionState logging and remove d...

2016-07-11 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

Minor: Improve PartitionState logging and remove duplication of code

Currently, logs involving PartitionState are not very helpful.

```
Broker 449 cached leader info 
org.apache.kafka.common.requests.UpdateMetadataRequest$PartitionState@3285d64a 
for partition prod-guts-out-main-shunt-23 in response to UpdateMetadata request 
sent by controller 356 epoch 138 with correlation id 0

TRACE state.change.logger: Broker 449 received LeaderAndIsr request 
org.apache.kafka.common.requests.LeaderAndIsrRequest$PartitionState@66d6a8eb 
correlation id 3 from controller 356 epoch 138 for partition 
[prod-guts-out-main-shunt,148]
```



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

$ git pull https://github.com/SinghAsDev/kafka partitionState

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

https://github.com/apache/kafka/pull/1609.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 #1609


commit 7a99fb2fb4531039bc195f870f84cdfe1358dfb2
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-07-11T20:31:29Z

Minor: Remove duplicated code for PartitionState and add toString override 
for better logging.




---
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 #1540: MINOR: Verify acls for group resource on all serve...

2016-06-22 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

MINOR: Verify acls for group resource on all servers of test cluster.



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

$ git pull https://github.com/SinghAsDev/kafka MinorAclTestCheck

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

https://github.com/apache/kafka/pull/1540.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 #1540


commit c8d0b88fa66ba5bde52feacd70d025e073362f05
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-06-22T20:19:08Z

MINOR: Verify acls for group resource on all servers of test cluster.




---
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 #1515: KAFKA-3849: Make consumer poll time in MirrorMaker...

2016-06-16 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3849: Make consumer poll time in MirrorMaker configurable



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3849

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

https://github.com/apache/kafka/pull/1515.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 #1515


commit ff45b7085d54ba9055b97b2139576f4b6213cf28
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-06-16T19:41:39Z

KAFKA-3849: Make consumer poll time in MirrorMaker configurable




---
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-3699: Update protocol page on website to...

2016-05-17 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3699: Update protocol page on website to explain how KIP-35 sho…

…uld be used

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3699

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

https://github.com/apache/kafka/pull/1395.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 #1395


commit ed56bd1ab8a4b9451b7edf05535aa23bc002de91
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-05-17T13:12:58Z

KAFKA-3699: Update protocol page on website to explain how KIP-35 should be 
used




---
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-3621: Add tests for ApiVersionRequest/Re...

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

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

KAFKA-3621: Add tests for ApiVersionRequest/Response



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3621

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

https://github.com/apache/kafka/pull/1275.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 #1275


commit dce48a70a1ef908fef85e046e8babdb65eb60667
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-04-27T18:48:40Z

KAFKA-3621: Add tests for ApiVersionRequest/Response




---
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: Git ignore idea's specific /out/ and .DS_Store...

2016-04-27 Thread SinghAsDev
Github user SinghAsDev closed the pull request at:

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


---
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: Git ignore idea's specific /out/ and .DS_Store...

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

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

Git ignore idea's specific /out/ and .DS_Store.



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

$ git pull https://github.com/SinghAsDev/kafka MinorGitignore

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

https://github.com/apache/kafka/pull/1274.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 #1274


commit 2a7f7a9e59bf9815f74de7d2d2771860b5e43ffb
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-04-27T17:08:19Z

Git ignore idea's specific /out/ and .DS_Store.




---
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-3600: Enhance java clients to use ApiVer...

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

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

KAFKA-3600: Enhance java clients to use ApiVersion Req/Resp to check if the 
broker they are talking to supports required api versions



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3600

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

https://github.com/apache/kafka/pull/1251.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 #1251






---
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: Update protocol doc link in Introductio...

2016-04-09 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

MINOR: Update protocol doc link in Introduction.



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

$ git pull https://github.com/SinghAsDev/kafka MinorFixDocLink

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

https://github.com/apache/kafka/pull/1211.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 #1211


commit eee578a929a2d7841aa1f434ece885b8e7cf5a5f
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-04-09T17:39:54Z

MINOR: Update protocol doc link in Introduction.




---
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 check for empty topics iterator in ...

2016-03-30 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

MINOR: Add check for empty topics iterator in ReplicaVerificationTool.



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

$ git pull https://github.com/SinghAsDev/kafka minorFixRelicaLagTool

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

https://github.com/apache/kafka/pull/1167.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 #1167


commit 5b5341f9f2168467595202ffa519f98831e7a0c4
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-30T23:40:44Z

MINOR: Add check for empty topics iterator in ReplicaVerificationTool.




---
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-3382: Add system test for ReplicationVer...

2016-03-28 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3382: Add system test for ReplicationVerificationTool



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3382

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

https://github.com/apache/kafka/pull/1160.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 #1160


commit f36649ae8c198dcec3595c83d475bb6cc3c174c9
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-11T20:19:24Z

KAFKA-3382: Add system test for ReplicationVerificationTool




---
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-3400: Fix describe topic in case there a...

2016-03-18 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3400: Fix describe topic in case there are zero partitions.



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3400

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

https://github.com/apache/kafka/pull/1086.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 #1086






---
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-3387: Update GetOffsetShell tool to not ...

2016-03-15 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3387: Update GetOffsetShell tool to not rely on old producer



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3387

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

https://github.com/apache/kafka/pull/1076.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 #1076


commit f1ad5a2dee9b451573f68259eda5081f52525029
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-14T23:50:19Z

KAFKA-3387: Update GetOffsetShell tool to not rely on old producer




---
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-3381: Add system test for SimpleConsumer...

2016-03-11 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3381: Add system test for SimpleConsumerShell



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3381

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

https://github.com/apache/kafka/pull/1053.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 #1053


commit 7ac3a93798f02516f132773739de27d8055f74a6
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-10T22:59:38Z

KAFKA-3381: Add system test for SimpleConsumerShell




---
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-3380: Add system test for GetOffsetShell...

2016-03-10 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3380: Add system test for GetOffsetShell tool



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3380

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

https://github.com/apache/kafka/pull/1048.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 #1048


commit fac6e9eada3c2b4b240939e6aba92e021e1a44fd
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-10T21:52:12Z

KAFKA-3380: Add system test for GetOffsetShell tool




---
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-3344: Remove previous system test's left...

2016-03-07 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3344: Remove previous system test's leftover test-log4j.properties



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3344

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

https://github.com/apache/kafka/pull/1024.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 #1024


commit 88fceb5de4d0065a14c16aa350be3397b68a3d48
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-07T21:09:02Z

KAFKA-3344: Remove previous system test's leftover test-log4j.properties




---
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-3334: Add a note on potential message lo...

2016-03-07 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3334: Add a note on potential message loss while using auto top…

…ics creation.

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3334

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

https://github.com/apache/kafka/pull/1022.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 #1022


commit d78df396dfbcc0b5e13765dfff33f54156cb9c5e
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-07T19:46:58Z

KAFKA-3334: Add a note on potential message loss while using auto topics 
creation.




---
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-3339: Fix java docs for seekToEnd and se...

2016-03-07 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3339: Fix java docs for seekToEnd and seekToBeginning.



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3339

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

https://github.com/apache/kafka/pull/1021.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 #1021


commit 56714878b519edae53fb14e8502aed5bd7a50137
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-07T19:20:22Z

KAFKA-3339: Fix java docs for seekToEnd and seekToBeginning.




---
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-3331: Refactor TopicCommand to make desc...

2016-03-04 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3331: Refactor TopicCommand to make describeTopic testable and …

…add unit tests.

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3331

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

https://github.com/apache/kafka/pull/1014.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 #1014


commit 835a54c5abffcfb31949a876cbcddeb077141c15
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-04T19:34:21Z

KAFKA-3331: Refactor TopicCommand to make describeTopic testable and add 
unit tests.




---
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-3247: Add option to see unbalanced parti...

2016-03-03 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3247: Add option to see unbalanced partitions via kafka-topic tool



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3247

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

https://github.com/apache/kafka/pull/1011.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 #1011


commit f4970d39e66d98dcc531a7f1c3acfacdf001c4ee
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-04T02:11:28Z

KAFKA-3247: Add option to see unbalanced partitions via kafka-topic tool




---
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-3252: Compression type from broker confi...

2016-03-03 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3252: Compression type from broker config should be used during log 
compaction.



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3252

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

https://github.com/apache/kafka/pull/1010.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 #1010


commit 3f447c28104a2b96b4dd2dad1709f7e04f0088ff
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-02T23:52:54Z

KAFKA-3252: Compression type from broker config should be used during log 
compaction.

commit 97a436028a519e143fb70700943c08ef2a714708
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-02T23:56:36Z

Fix using of convertedMessage

commit 94041c2247a234f0069f7b0426948ad203b79572
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-03-04T00:25:05Z

Add UT




---
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-3307: Add ProtocolVersion request/respon...

2016-02-29 Thread SinghAsDev
GitHub user SinghAsDev reopened a pull request:

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

KAFKA-3307: Add ProtocolVersion request/response and server side handling.

The patch does the following.
1. For unknown requests or protocol versions, broker sends an empty 
response, instead of simple closing the connection.
2. Adds ProtocolVersion request and response, and server side 
implementation.

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3307

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

https://github.com/apache/kafka/pull/986.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 #986


commit 3765aa58300f5ffc6997cad22e86ad90f383129e
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-02-29T00:42:36Z

Init patch. Add req/resp. Add req handling. Add basic ut.

commit e4465910e94cf3300589f94aeeafe55c0ff7ed3e
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-02-29T04:23:52Z

Respond with empty response body for invalid requests

commit 2985d6dad7241092c8fe9170d56e85f621d8fa1b
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-02-29T04:28:40Z

Remove commented code

commit 3f103945afee264a9a5d663c6a8048e1388896ad
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-02-29T22:14:28Z

Add mechanism to deprecate a protocol version. Populate ProtocolVersion's 
apiDeprecatedVersions using this mechanism.




---
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-3307: Add ProtocolVersion request/respon...

2016-02-29 Thread SinghAsDev
Github user SinghAsDev closed the pull request at:

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


---
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 3307: Add ProtocolVersion request/respon...

2016-02-29 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

Kafka 3307: Add ProtocolVersion request/response and server side handling.



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3307

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

https://github.com/apache/kafka/pull/986.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 #986


commit 3765aa58300f5ffc6997cad22e86ad90f383129e
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-02-29T00:42:36Z

Init patch. Add req/resp. Add req handling. Add basic ut.

commit e4465910e94cf3300589f94aeeafe55c0ff7ed3e
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-02-29T04:23:52Z

Respond with empty response body for invalid requests

commit 2985d6dad7241092c8fe9170d56e85f621d8fa1b
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-02-29T04:28:40Z

Remove commented code

commit 3f103945afee264a9a5d663c6a8048e1388896ad
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-02-29T22:14:28Z

Add mechanism to deprecate a protocol version. Populate ProtocolVersion's 
apiDeprecatedVersions using this mechanism.




---
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-3221: Pass requesting user information t...

2016-02-18 Thread SinghAsDev
Github user SinghAsDev closed the pull request at:

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


---
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-3243: Fix Kafka basic ops documentation ...

2016-02-16 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3243: Fix Kafka basic ops documentation for Mirror maker, black…

…list is not supported for new consumers

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3243

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

https://github.com/apache/kafka/pull/923.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 #923


commit cf8315c9ca600a4137e07fb95a0ffb477fe43a4b
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-02-16T23:35:57Z

KAFKA-3243: Fix Kafka basic ops documentation for Mirror maker, blacklist 
is not supported for new consumers




---
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-3187: Make kafka-acls.sh help messages m...

2016-02-09 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3187: Make kafka-acls.sh help messages more generic.



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3187

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

https://github.com/apache/kafka/pull/892.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 #892


commit bdcef12a01de88d5fcc7ac7225f45030d22b8762
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-02-09T21:24:32Z

KAFKA-3187: Make kafka-acls.sh help messages more generic.




---
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-3221: Pass requesting user information t...

2016-02-09 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3221: Pass requesting user information to authorizer to enable …

…user authorization before modifying acls.

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3221

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

https://github.com/apache/kafka/pull/895.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 #895


commit 0378232be9997be41c6417131549863bd7a972c6
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-02-10T02:46:02Z

KAFKA-3221: Pass requesting user information to authorizer to enable user 
authorization before modifying acls.




---
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-3186: Make Kafka authorizer aware of pri...

2016-02-03 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3186: Make Kafka authorizer aware of principal types it supports.



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3186

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

https://github.com/apache/kafka/pull/861.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 #861


commit 0617c75ee808d58009afdaf976fc1ae455cfb2e8
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-02-04T01:06:29Z

KAFKA-3186: Make Kafka authorizer aware of principal types it supports.




---
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-3140: Fix PatternSyntaxException and han...

2016-01-22 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3140: Fix PatternSyntaxException and hand caused by it in Mirro…

Fix PatternSyntaxException and hand caused by it in MirrorMaker on passing 
invalid java regex string as whitelist

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3140

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

https://github.com/apache/kafka/pull/805.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 #805


commit 0f120f976ce66e37cb5180df2b024def1cfcd6bb
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-01-22T22:22:05Z

KAFKA-3140: Fix PatternSyntaxException and hand caused by it in MirrorMaker 
on passing invalid java regex string as whitelist.




---
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-3141: Skip misformed properties instead ...

2016-01-22 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3141: Skip misformed properties instead of throwing ArrayIndexO…

Skip misformed properties instead of throwing ArrayIndexOutOfBoundsException

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3141

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

https://github.com/apache/kafka/pull/806.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 #806


commit c7ff10bdde3482db2d594faaa6760ea5c0137c0b
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-01-23T00:24:15Z

KAFKA-3141: Skip misformed properties instead of throwing 
ArrayIndexOutOfBoundsException




---
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 3078

2016-01-08 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

Kafka 3078



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3078

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

https://github.com/apache/kafka/pull/747.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 #747


commit 52a9e37f7cee7b6d565dbf9da28595ce6de85c74
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-01-07T22:32:51Z

KAFKA-3077: Enable KafkaLog4jAppender to work with SASL enabled brokers

commit ddd1e1d0644eb6dc1e6fbb834b237e01a943ed8d
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-01-09T00:01:58Z

KAFKA-3078: Add ducktape tests for KafkaLog4jAppender producing to SASL 
enabled Kafka cluster




---
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-3077: Enable KafkaLog4jAppender to work ...

2016-01-07 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-3077: Enable KafkaLog4jAppender to work with SASL enabled brokers



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-3077

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

https://github.com/apache/kafka/pull/740.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 #740


commit 52a9e37f7cee7b6d565dbf9da28595ce6de85c74
Author: Ashish Singh <asi...@cloudera.com>
Date:   2016-01-07T22:32:51Z

KAFKA-3077: Enable KafkaLog4jAppender to work with SASL enabled brokers




---
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-2846: Add Ducktape test for kafka-consum...

2015-11-18 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2846: Add Ducktape test for kafka-consumer-groups



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2846

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

https://github.com/apache/kafka/pull/555.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 #555


commit 623cffab6f6154242546607ee5acf680aef7c9d8
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-11-19T00:28:53Z

KAFKA-2846: Add Ducktape test for kafka-consumer-groups




---
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 2746

2015-11-16 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

Kafka 2746



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2746

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

https://github.com/apache/kafka/pull/534.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 #534


commit 3c33198d9cdb731ae6273c80c0d81699c8e92ce0
Author: Ismael Juma <ism...@juma.me.uk>
Date:   2015-11-13T21:43:34Z

Do not use ZKUtils in `ConsumerGroupCommand` if `new-consumer` is used

commit 28d5992bf91388623c3b4ed91f947dbc9b37a8da
Author: Ismael Juma <ism...@juma.me.uk>
Date:   2015-11-13T22:31:14Z

Reuse consumer and accept consumer.config option

Also improve error message if delete is used with new-consumer.

commit 2bc64b56493935eab5c704ef13751ceb6a8eb57c
Author: Ismael Juma <ism...@juma.me.uk>
Date:   2015-11-13T22:49:57Z

Remove `consumer.config` for now

It may be better to reuse `config`.

commit 0e586a6b766cb9674586e346fdd29154162f3fa1
Author: Ismael Juma <ism...@juma.me.uk>
Date:   2015-11-13T23:12:43Z

Fix NPE when committed returns null

commit fe6070408f6042d22033c4d31a604ef0b3cbaa01
Author: Ismael Juma <ism...@juma.me.uk>
Date:   2015-11-13T23:48:12Z

Set GROUP_ID_CONFIG in consumer correctly based on received option

Bug spotted by Jason.

commit d9fe30ed24eaaeb59c3aabaff736359f3b38a375
Author: Ismael Juma <ism...@juma.me.uk>
Date:   2015-11-14T11:26:41Z

Create consumer lazily in `KafkaConsumerGroupService`

We need a group-id to create a consumer, but a consumer is not
needed for `list()`. This avoids a NPE while trying to get a non-existent
group-id during `list()` spotted by Jun.

commit 426bbf032a95f974e2929f3ef080a41f060399e2
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-11-16T00:32:01Z

KAFKA-2746: Add support for using ConsumerGroupCommand on secure install




---
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-2822: DescribeConsumerGroup now returns ...

2015-11-12 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2822: DescribeConsumerGroup now returns empty list for non-exis…

…tent group, it used to throw IllegalArgumentException

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2822

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

https://github.com/apache/kafka/pull/515.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 #515


commit 72fc78d2944ad21a35ac7302ba02750f47101b52
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-11-12T20:10:08Z

KAFKA-2822: DescribeConsumerGroup now returns empty list for non-existent 
group, it used to throw IllegalArgumentException




---
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 unreachable if check

2015-11-12 Thread SinghAsDev
Github user SinghAsDev closed the pull request at:

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


---
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: Improve exception message that gets thr...

2015-11-09 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

MINOR: Improve exception message that gets thrown for non-existent group



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

$ git pull https://github.com/SinghAsDev/kafka ExceptionMessage

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

https://github.com/apache/kafka/pull/471.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 #471


commit 4bc9167fba19d9dc538fb090ef0e58ca241365e4
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-11-09T20:46:20Z

MINOR: Improve exception message that gets thrown for non-existent group




---
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-2768: New-consumer sends invalid describ...

2015-11-06 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2768: New-consumer sends invalid describeGroupResponse while re…

…stabilizing

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2768

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

https://github.com/apache/kafka/pull/447.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 #447


commit 547f1b2f1c46cc4c09bbd334bcc9e1db7fc7cbd8
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-11-06T22:34:38Z

KAFKA-2768: New-consumer sends invalid describeGroupResponse while 
restabilizing




---
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 2761

2015-11-06 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

Kafka 2761



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2761

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

https://github.com/apache/kafka/pull/445.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 #445


commit ea27a8cbc80d5adcf5ed31586ff090bd91fd88b9
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-11-06T06:49:37Z

KAFKA-2734: kafka-console-consumer throws NoSuchElementException on not 
specifying topic

commit ed75c47d9b7e04bee15b480f6e69e7e3648bd1ec
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-11-05T00:48:18Z

KAFKA-2761: Enable passing regex via whitelist for new-consumer in 
ConsoleConsumer




---
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-2755: NPE thrown while handling Describe...

2015-11-05 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2755: NPE thrown while handling DescribeGroup request for non-e…

…xistent consumer group

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2755

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

https://github.com/apache/kafka/pull/435.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 #435


commit d5e3e9dbc0dd15ed7e30c1137d185df10060cb6b
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-11-05T20:29:03Z

KAFKA-2755: NPE thrown while handling DescribeGroup request for 
non-existent consumer group




---
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-2760: Clean up interface of AdminClient....

2015-11-05 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2760: Clean up interface of AdminClient.describeConsumerGroup(g…

…roupId)

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2760

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

https://github.com/apache/kafka/pull/442.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 #442


commit 774eed74b670fd945f1122f91a748140dae6509e
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-11-06T06:16:39Z

KAFKA-2760: Clean up interface of AdminClient.describeConsumerGroup(groupId)




---
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-2734: kafka-console-consumer throws NoSu...

2015-11-03 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2734: kafka-console-consumer throws NoSuchElementException on n…

…ot specifying topic

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2734

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

https://github.com/apache/kafka/pull/412.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 #412


commit 1b8522773d2ff799bb2228c5003d8fce5dcd4e86
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-11-03T22:42:21Z

KAFKA-2734: kafka-console-consumer throws NoSuchElementException on not 
specifying topic




---
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-2716: Make Kafka core not depend on log4...

2015-11-02 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2716: Make Kafka core not depend on log4j-appender



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2716

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

https://github.com/apache/kafka/pull/405.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 #405


commit d4d69ab4fec81efd18eee68303291bb90dc4ca29
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-11-02T18:54:28Z

KAFKA-2716: Make Kafka core not depend on log4j-appender




---
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: HOTFIX: log4j-appender not getting built

2015-10-30 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

HOTFIX: log4j-appender not getting built



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

$ git pull https://github.com/SinghAsDev/kafka HOTFIX-Log4jAppender

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

https://github.com/apache/kafka/pull/395.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 #395


commit ad5f992a9a5f18e2d4286f9f10735d3e179a9c26
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-10-30T23:46:20Z

HOTFIX: log4j-appender not getting built




---
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 unreachable if check

2015-10-30 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

MINOR: Remove unreachable if check

@gwenshap @granders could you guys take a look at this trivial change. This 
piece makes one think that for SSL, not passing `new_consumer=True` should be 
fine. It was fine until recently.

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

$ git pull https://github.com/SinghAsDev/kafka MinorTestChange

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

https://github.com/apache/kafka/pull/396.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 #396


commit 7d7c9d339e6e98e73610c339960c55e42987c9c9
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-10-31T00:05:00Z

MINOR: Remove unreachable if check




---
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: fix checkstyle failures

2015-10-21 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

MINOR: fix checkstyle failures

@guozhangwang could you take a look at this. These failures are a bit 
annoying as it never leads to a successful build.

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

$ git pull https://github.com/SinghAsDev/kafka fixCheckstyle

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

https://github.com/apache/kafka/pull/347.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 #347


commit 4dacf8b7c014a186bca2737b5f93e190d58f43ff
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-10-21T21:18:51Z

MINOR: fix checkstyle failures




---
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: fix checkstyle failures

2015-10-21 Thread SinghAsDev
Github user SinghAsDev closed the pull request at:

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


---
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-2671: Enable starting Kafka server with ...

2015-10-19 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2671: Enable starting Kafka server with a Properties object



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2671

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

https://github.com/apache/kafka/pull/330.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 #330


commit 3924b1da522f257bc45d51b98af247208dfc210c
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-10-19T20:21:08Z

KAFKA-2671: Enable starting Kafka server with a Properties object




---
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-2574: Add ducktape based ssl test for Ka...

2015-10-15 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2574: Add ducktape based ssl test for KafkaLog4jAppender



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2574

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

https://github.com/apache/kafka/pull/319.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 #319


commit 0b1ec012ab471e2ad22e9b11e54f364af1586de5
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-10-13T21:49:42Z

KAFKA-2574: Add ducktape based ssl test for KafkaLog4jAppender




---
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-2487: change kafka.examples.Consumer to ...

2015-10-12 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2487: change kafka.examples.Consumer to use the new java consumer



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2487

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

https://github.com/apache/kafka/pull/297.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 #297


commit 97fbdc78ceb9e48e32ea6108f6a4852da25cc91f
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-09-11T22:35:47Z

KAFKA-2487: change kafka.examples.Consumer to use the new java 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-2490: support new consumer in ConsumerGr...

2015-10-12 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2490: support new consumer in ConsumerGroupCommand



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2490

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

https://github.com/apache/kafka/pull/299.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 #299


commit 73ad826fb653c975dd4f8983219e611045d87ed7
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-09-21T17:46:47Z

KAFKA-2490: support new consumer in ConsumerGroupCommand




---
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-2531: Add Ducktape based tests for Kafka...

2015-09-23 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2531: Add Ducktape based tests for KafkaLog4jAppender



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2531

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

https://github.com/apache/kafka/pull/235.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 #235


commit a0880587b94a20c97475de4bc27db3d0fe14221b
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-09-22T23:21:27Z

KAFKA-2531: Add Ducktape based tests for KafkaLog4jAppender




---
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: KafkaLog4jAppender dies while specifying acks ...

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

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

KafkaLog4jAppender dies while specifying acks config



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2571

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

https://github.com/apache/kafka/pull/231.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 #231


commit 74ba74504b5d20cbf5b0b06b6f54373cb8785cdf
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-09-22T23:19:51Z

KafkaLog4jAppender dies while specifying acks config




---
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-2533: Create a member Metadata.Listener ...

2015-09-16 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2533: Create a member Metadata.Listener inside KafkaConsumer



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2533

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

https://github.com/apache/kafka/pull/220.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 #220


commit 7f1a85ddd2f1200362424959349235b013112009
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-09-11T21:39:55Z

KAFKA-2533: Create a member Metadata.Listener inside KafkaConsumer




---
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: Fix trace/debug logs in RequestChannel

2015-09-03 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

MINOR: Fix trace/debug logs in RequestChannel



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2461-2

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

https://github.com/apache/kafka/pull/192.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 #192


commit 0dd423549f4ea47729d7e5b42ee364b5020f9b2d
Author: Ashish Singh <asi...@cloudera.com>
Date:   2015-09-03T20:20:25Z

MINOR: Fix trace/debug logs in RequestChannel




---
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-2447: Add capability to KafkaLog4jAppend...

2015-08-28 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2447: Add capability to KafkaLog4jAppender to be able to use SSL



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2447

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

https://github.com/apache/kafka/pull/175.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 #175


commit d963a19cb3c47fd56f12afd935d35afb0e2be822
Author: asingh asi...@cloudera.com
Date:   2015-08-28T04:16:43Z

KAFKA-2447: Add capability to KafkaLog4jAppender to be able to use SSL




---
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-2468: SIGINT during Kafka server startup...

2015-08-25 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2468: SIGINT during Kafka server startup can leave server deadlocked

As we handle exceptions or invalid states in Kafka server by shutting it 
down, there is no reason to use exit() and not halt() in shutdown itself.

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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2468

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

https://github.com/apache/kafka/pull/167.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 #167


commit 6b5954fb2747f9c94289ad4a75873131b7f55d0a
Author: asingh asi...@cloudera.com
Date:   2015-08-25T07:34:42Z

KAFKA-2468: SIGINT during Kafka server startup can leave server deadlocked




---
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-2461: request logger no longer logs extr...

2015-08-25 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-2461: request logger no longer logs extra information in debug mode



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-2461

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

https://github.com/apache/kafka/pull/169.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 #169


commit 6cce97cef5ab52c394a94c8a2062f543ee6d4d81
Author: asingh asi...@cloudera.com
Date:   2015-08-25T22:32:56Z

KAFKA-2461: request logger no longer logs extra information in debug mode




---
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-1893: Allow regex subscriptions in the n...

2015-08-10 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request:

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

KAFKA-1893: Allow regex subscriptions in the new consumer



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

$ git pull https://github.com/SinghAsDev/kafka KAFKA-1893

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

https://github.com/apache/kafka/pull/128.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 #128


commit 7294571b853979f85685ae6a49a4711202a64c04
Author: asingh asi...@cloudera.com
Date:   2015-07-28T00:05:48Z

KAFKA-1893: Allow regex subscriptions in the new 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.
---