[GitHub] kafka pull request #1820: MINOR: Add timeout to testRenegotiation.
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...
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 ...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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 ...
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...
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...
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 ...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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 ...
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...
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...
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...
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...
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 ...
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
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 ...
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...
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
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 ...
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
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...
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...
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
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...
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....
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...
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...
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
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
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
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
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 ...
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...
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 ...
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...
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...
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 ...
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 ...
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
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...
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...
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...
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...
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. ---