Re: [DISCUSS] KIP-932: Queues for Kafka

2023-05-23 Thread Ashish Chhabria
This is such a great proposal. Parallel/Cooperative consumption is a long missing pattern in Apache Kafka and it is a viable solution for the common head-of-line-blocking problem. Developers have long attempted to solve this with bespoke consumer proxies that state manage the inflight payloads, so

RE: [EXTERNAL] Re: Security vulnerabilities in kafka:2.13-2.6.0/2.7.0 docker image

2021-09-01 Thread Ashish Patil
Hi Team I tried upgrading it to 2.13_2.8.0 but still have these vulnerabilities. [cid:image003.jpg@01D79F3D.5BA06A20] What is your suggestion on this? Thanks Ashish From: Jake Murphy Smith Sent: 01 September 2021 09:31 To: Ashish Patil Subject: RE: [EXTERNAL] Re: Security vulnerabilities in

Security vulnerabilities in kafka:2.13-2.6.0/2.7.0 docker image

2021-08-31 Thread Ashish Patil
we have any plan to fix this in the coming version or any suggestions around this? Thanks Ashish

[jira] [Created] (KAFKA-10608) Add support for rolling upgrade with topology changes

2020-10-13 Thread Ashish Surana (Jira)
Ashish Surana created KAFKA-10608: - Summary: Add support for rolling upgrade with topology changes Key: KAFKA-10608 URL: https://issues.apache.org/jira/browse/KAFKA-10608 Project: Kafka

[jira] [Created] (KAFKA-8596) Kafka topic pre-creation error message needs to be passed to application as an exception

2019-06-25 Thread ASHISH M VYAS (JIRA)
ASHISH M VYAS created KAFKA-8596: Summary: Kafka topic pre-creation error message needs to be passed to application as an exception Key: KAFKA-8596 URL: https://issues.apache.org/jira/browse/KAFKA-8596

[jira] [Created] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

2018-07-10 Thread Ashish Surana (JIRA)
Ashish Surana created KAFKA-7149: Summary: Reduce assignment data size to improve kafka streams scalability Key: KAFKA-7149 URL: https://issues.apache.org/jira/browse/KAFKA-7149 Project: Kafka

[jira] [Created] (KAFKA-6642) Rack aware replica assignment in kafka streams

2018-03-12 Thread Ashish Surana (JIRA)
Ashish Surana created KAFKA-6642: Summary: Rack aware replica assignment in kafka streams Key: KAFKA-6642 URL: https://issues.apache.org/jira/browse/KAFKA-6642 Project: Kafka Issue Type: New

[jira] [Created] (KAFKA-6555) Making state store queryable during restoration

2018-02-12 Thread Ashish Surana (JIRA)
Ashish Surana created KAFKA-6555: Summary: Making state store queryable during restoration Key: KAFKA-6555 URL: https://issues.apache.org/jira/browse/KAFKA-6555 Project: Kafka Issue Type

[jira] [Created] (KAFKA-5504) Kafka controller is not getting elected

2017-06-22 Thread Ashish Kumar (JIRA)
Ashish Kumar created KAFKA-5504: --- Summary: Kafka controller is not getting elected Key: KAFKA-5504 URL: https://issues.apache.org/jira/browse/KAFKA-5504 Project: Kafka Issue Type: Bug

Re: [jira] [Commented] (KAFKA-4379) Remove caching of dirty and removedkeys from StoreChangeLogger

2017-04-28 Thread Ashish
Bc Sent from my iPhone B > On 25-Apr-2017, at 10:21, ASF GitHub Bot (JIRA) wrote: > >This message is eligible for Automatic Cleanup! (j...@apache.org) Add > cleanup rule | More info > >[ > https://issues.apache.org/jira/browse/KAFKA-4379?page=com.atlassian.jira.plugin.system.issuetab

[subscribe Request]

2017-02-07 Thread Ashish Singh
Hi Team, I would like to subscribe to Kafka dev group Thanks, Ashish Singh

[jira] [Commented] (KAFKA-4541) Add capability to create delegation token

2016-12-15 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15752982#comment-15752982 ] Ashish K Singh commented on KAFKA-4541: --- Yes, it will. > Add capability to

[jira] [Created] (KAFKA-4542) Add authentication based on delegation token.

2016-12-14 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-4542: - Summary: Add authentication based on delegation token. Key: KAFKA-4542 URL: https://issues.apache.org/jira/browse/KAFKA-4542 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

2016-12-14 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15749769#comment-15749769 ] Ashish K Singh commented on KAFKA-1696: --- [~omkreddy] I had to convert this

[jira] [Updated] (KAFKA-4544) Add system tests for delegation token based authentication

2016-12-14 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-4544: -- Description: Add system tests for delegation token based authentication. (was: Add capability

[jira] [Assigned] (KAFKA-4541) Add capability to create delegation token

2016-12-14 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh reassigned KAFKA-4541: - Assignee: Ashish K Singh > Add capability to create delegation to

[jira] [Updated] (KAFKA-4544) Add system tests for delegation token based authentication

2016-12-14 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-4544: -- Summary: Add system tests for delegation token based authentication (was: Add capability to

[jira] [Created] (KAFKA-4543) Add capability to renew/expire delegation tokens.

2016-12-14 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-4543: - Summary: Add capability to renew/expire delegation tokens. Key: KAFKA-4543 URL: https://issues.apache.org/jira/browse/KAFKA-4543 Project: Kafka Issue Type

[jira] [Created] (KAFKA-4544) Add capability to renew/expire delegation tokens.

2016-12-14 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-4544: - Summary: Add capability to renew/expire delegation tokens. Key: KAFKA-4544 URL: https://issues.apache.org/jira/browse/KAFKA-4544 Project: Kafka Issue Type

[jira] [Created] (KAFKA-4541) Add capability to create delegation token

2016-12-14 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-4541: - Summary: Add capability to create delegation token Key: KAFKA-4541 URL: https://issues.apache.org/jira/browse/KAFKA-4541 Project: Kafka Issue Type: Sub

[jira] [Updated] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

2016-12-14 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-1696: -- Issue Type: New Feature (was: Sub-task) Parent: (was: KAFKA-1682) > Kafka sho

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

2016-12-13 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746886#comment-15746886 ] Ashish K Singh commented on KAFKA-1696: --- [~omkreddy] as I indicated on discuss

Re: [DISCUSS] KIP-48 Support for delegation tokens as an authentication mechanism

2016-12-12 Thread Ashish Singh
with the following: > > 1. Protocol and Config changes > > 2. format of the data stored in ZK. > > 3. Changes to Java Clients/Usage of SASL SCRAM mechanism > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > > 48+Delegation+token+support+f

Re: Reg: ACLS

2016-12-09 Thread Ashish Singh
e). So Kerberos and SSL are not required (although commonly used). > > Ismael > > On Fri, Dec 9, 2016 at 6:59 PM, Ashish Singh wrote: > > > Hey, > > > > No it does not. Without kerberos or ssl, all requests will appear to come > > from anonymous user, and

Re: Reg: ACLS

2016-12-09 Thread Ashish Singh
upport ACL's with out kerberos/SSL? > > Any info on this would be greatly helpful. > > > Thanks > -- Regards, Ashish

Re: [DISCUSS] KIP-97: Improved Kafka Client RPC Compatibility Policy

2016-12-02 Thread Ashish Singh
On Wed, Nov 30, 2016, at 11:17, Colin McCabe wrote: > > Thanks, Ashish. I think the idea of having the client make an > > ApiVersionRequest call when it starts up is a good one. This idea is > > described in both KIP-97, and the KAFKA-3600 patches. I also think we > > ought

[jira] [Created] (KAFKA-4482) Kafka streams test failure and hang causing PR builds to fail

2016-12-02 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-4482: - Summary: Kafka streams test failure and hang causing PR builds to fail Key: KAFKA-4482 URL: https://issues.apache.org/jira/browse/KAFKA-4482 Project: Kafka

Re: [DISCUSS] KIP-97: Improved Kafka Client RPC Compatibility Policy

2016-11-30 Thread Ashish Singh
happy to rebase KAFKA-3600 on trunk. However, any comments/ feedback on KAFKA-3600's approach on maintaining api version info for each connected broker is highly welcome. On Wed, Nov 30, 2016 at 5:47 AM, Ismael Juma wrote: > Thanks Colin, I think this is a good improvement. > > Ashis

[jira] [Resolved] (KAFKA-3309) Update Protocol Documentation WIP patch

2016-11-30 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh resolved KAFKA-3309. --- Resolution: Duplicate > Update Protocol Documentation WIP pa

Re: [DISCUSS] KIP-97: Improved Kafka Client RPC Compatibility Policy

2016-11-29 Thread Ashish Singh
On Tue, Nov 29, 2016 at 4:11 PM, Colin McCabe wrote: > On Tue, Nov 29, 2016, at 11:39, Ashish Singh wrote: > > Hello Colin, > > > > In the KIP you mentioned that currently the client uses supported api > > versions information to check if the server supports its de

Re: [DISCUSS] KIP-97: Improved Kafka Client RPC Compatibility Policy

2016-11-29 Thread Ashish Singh
icy. If you're interested, please check out: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 97%3A+Improved+Kafka+Compatibility+Policy > > > > cheers, > > Colin > -- Regards, Ashish

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

2016-11-29 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15706209#comment-15706209 ] Ashish K Singh commented on KAFKA-1696: --- [~omkreddy] would you be able to pro

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

2016-11-29 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15706077#comment-15706077 ] Ashish K Singh commented on KAFKA-1696: --- It has been a while, since any prog

[Subscribe]

2016-11-11 Thread Ashish Singh
Please subscribe me to this group

Re: [DISCUSS] KIP-48 Support for delegation tokens as an authentication mechanism

2016-09-29 Thread Ashish Singh
ntalapani > wrote: > > The only pending update for the KIP is to write up the protocol changes > like > > we've it KIP-4. I'll update the wiki. > > > > > > On Thu, Sep 15, 2016 at 4:27 PM Ashish Singh > wrote: > >> > >> I think we dec

Re: [DISCUSS] KIP-48 Support for delegation tokens as an authentication mechanism

2016-09-15 Thread Ashish Singh
ssion was dead for a while. Are there still contentious > points? If not, why are there no votes? > > On Tue, Aug 23, 2016 at 1:26 PM, Jun Rao wrote: > > Ashish, > > > > Yes, I will send out a KIP invite for next week to discuss KIP-48 and > other > > remaining

Re: [VOTE] 0.10.1 Release Plan

2016-09-13 Thread Ashish Singh
confluence/display/KAFKA/Release+Plan+0.10.1. I > > went ahead and included KIP-55 since Jun said it may have a chance, but > > note that in-progress KIPs will only be included if they are ready by the > > feature freeze date (Sep. 17). We'll evaluate KIP-79 once we see Becket's > > patch. > > > > Thanks, > > Jason > > > -- Regards, Ashish

[jira] [Commented] (KAFKA-4145) Avoid redundant integration testing in ProducerSendTests

2016-09-09 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15478402#comment-15478402 ] Ashish K Singh commented on KAFKA-4145: --- +1, testFlush has been one of the

Re: [ANNOUNCE] New committer: Jason Gustafson

2016-09-06 Thread Ashish Singh
contributed numerous patches to a wide range of areas, > > > notably > > > > > within the new consumer and the Kafka Connect layers. He has > > displayed > > > > > great taste and judgement which has been apparent through his > > > involvement > > > > > across the board from mailing lists, JIRA, code reviews to > > contributing > > > > > features, bug fixes and code and documentation improvements. > > > > > > > > > > Thank you for your contribution and welcome to Apache Kafka, Jason! > > > > > -- > > > > > Thanks, > > > > > Neha > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > -- Ashish 🎤h

[jira] [Commented] (KAFKA-3148) SslSelectorTest.testRenegotiation can hang on slow boxes

2016-09-01 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15457099#comment-15457099 ] Ashish K Singh commented on KAFKA-3148: --- [~revans2] since you have figured out

Re: [DISCUSS] KIP-76: Enable getting password from executable rather than passing as plaintext in config files

2016-08-25 Thread Ashish Singh
harder to find than files on disk. - The perms also protect the executable. - The file sits on an ephemeral disk that’s mounted to memory, so stealing a physical disk won’t result in getting even the encrypted password. On Thu, Aug 25, 2016 at 9:07 AM, Gwen Shapira wrote: Hi Ashish

[DISCUSS] KIP-76: Enable getting password from executable rather than passing as plaintext in config files

2016-08-24 Thread Ashish Singh
he.org/jira/browse/KAFKA-2629 POC: https://github.com/apache/kafka/pull/1770 Thanks -- Regards, Ashish

Re: Kafka KIP meeting Aug 23 at 11:00am PST

2016-08-23 Thread Ashish Singh
KIP-48 delegation token : Ashish will ping Harsh to see if this is still active. Harsha just replied and he will be willing to join in next KIP call to discuss more about KIP-48. On Tue, Aug 23, 2016 at 1:22 PM, Jun Rao wrote: The following are the notes from today's KIP discu

Re: [DISCUSS] KIP-48 Support for delegation tokens as an authentication mechanism

2016-08-23 Thread Ashish Singh
10 PM, Harsha Chintalapani wrote: > Ashish, > Yes we are working on it. Lets discuss in the next KIP meeting. > I'll join. > -Harsha > > On Tue, Aug 23, 2016 at 12:07 PM Ashish Singh wrote: > > > Hello Harsha, > > > > Are you still working on thi

Re: [DISCUSS] KIP-48 Support for delegation tokens as an authentication mechanism

2016-08-23 Thread Ashish Singh
Hello Harsha, Are you still working on this? Wondering if we can discuss this in next KIP meeting, if you can join. On Mon, Jul 18, 2016 at 9:51 AM, Harsha Chintalapani wrote: > Hi Grant, > We are working on it. Will add the details to KIP about the > request protocol. > > Thanks, > H

[jira] [Commented] (KAFKA-2629) Enable getting SSL password from an executable rather than passing plaintext password

2016-08-22 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15431725#comment-15431725 ] Ashish K Singh commented on KAFKA-2629: --- [~bharatviswa] just posted a WIP p

Re: [ANNOUNCE] New Kafka PMC member Gwen Shapira

2016-08-18 Thread Ashish Singh
; Kafka > > > PMC. > > > > > > Congratulations, Gwen! > > > > > > Jun > > > > > > > > > -- > Grant Henke > Software Engineer | Cloudera > gr...@cloudera.com | twitter.com/gchenke | > linkedin.com/in/granthenke > -- Ashish 🎤h

[jira] [Updated] (KAFKA-4052) Allow passing properties file to ProducerPerformance

2016-08-16 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-4052: -- Status: Patch Available (was: Open) > Allow passing properties file to ProducerPerforma

[jira] [Created] (KAFKA-4052) Allow passing properties file to ProducerPerformance

2016-08-16 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-4052: - Summary: Allow passing properties file to ProducerPerformance Key: KAFKA-4052 URL: https://issues.apache.org/jira/browse/KAFKA-4052 Project: Kafka Issue

Re: Review request for KAFKA-3600

2016-08-15 Thread Ashish Singh
reviewer here) who understands and agrees with > the design improves the discussion a lot. > > Gwen > > On Mon, Aug 15, 2016 at 8:27 AM, Ashish Singh wrote: > > Hello Dana, > > > > Thanks for the feedback. > > > > Kafka-3600 is not intended to address bac

Re: Review request for KAFKA-3600

2016-08-15 Thread Ashish Singh
ersion > necessary? These aren't used in the kafka-python implementation, so > from my perspective the answer is no. But maybe the java community has > some interesting ideas for improvement where these are key > ingredients. In any case, I think it would probably help substantially >

[jira] [Commented] (KAFKA-2629) Enable getting SSL password from an executable rather than passing plaintext password

2016-08-12 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418943#comment-15418943 ] Ashish K Singh commented on KAFKA-2629: --- [~harsha_ch] any thoughts? >

[jira] [Commented] (KAFKA-2629) Enable getting SSL password from an executable rather than passing plaintext password

2016-08-12 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418941#comment-15418941 ] Ashish K Singh commented on KAFKA-2629: --- [~bharatviswa] the way we do it is

Re: Review request for KAFKA-3600

2016-08-12 Thread Ashish Singh
why I responded as I did... > > Verification is good, but it looked like there was much complexity > added toward very little benefits. > > On Thu, Aug 11, 2016 at 3:37 PM, Ashish Singh wrote: > > Hey Gwen, > > > > I think this was more than a verification

Re: Review request for KAFKA-3600

2016-08-11 Thread Ashish Singh
applications of incompatible broker versions, I think that is some value add. In future, the api versions info can be used to take smarter decisions. On Wed, Aug 10, 2016 at 11:04 PM, Gwen Shapira wrote: > I hate doing this, because Ashish has really been good about following > up on the P

Re: Review request for KAFKA-3600

2016-08-09 Thread Ashish Singh
Provided wrong link to PR, here is the PR <https://github.com/apache/kafka/pull/1251> for KAFKA-3600. On Tue, Aug 9, 2016 at 9:45 AM, Ashish Singh wrote: > Hey Guys, > > KAFKA-3600 <https://issues.apache.org/jira/browse/KAFKA-3600> was part of > KIP-35's

Review request for KAFKA-3600

2016-08-09 Thread Ashish Singh
nder review. Here is the PR <https://github.com/apache/kafka/pull/986> I have addressed all review comments and have been waiting for further reviews/ this to go in for quite some time. I will really appreciate if a committer can help with making progress on this. -- Regards, Ashish

[jira] [Commented] (KAFKA-2629) Enable getting SSL password from an executable rather than passing plaintext password

2016-08-09 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15413738#comment-15413738 ] Ashish K Singh commented on KAFKA-2629: --- [~bharatviswa] I would like this to g

[jira] [Commented] (KAFKA-2630) Add Namespaces to Kafka

2016-08-08 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15412553#comment-15412553 ] Ashish K Singh commented on KAFKA-2630: --- [~vahid] apologies for the del

[jira] [Commented] (KAFKA-3252) compression type for a topic should be used during log compaction

2016-07-12 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15373182#comment-15373182 ] Ashish K Singh commented on KAFKA-3252: --- [~junrao] [~omkreddy] what should be

[jira] [Commented] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected

2016-06-28 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15353497#comment-15353497 ] Ashish K Singh commented on KAFKA-3822: --- [~hachikuji] while working out a PO

[jira] [Commented] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected

2016-06-27 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351574#comment-15351574 ] Ashish K Singh commented on KAFKA-3822: --- [~hachikuji] yeah makes sense. Will ha

Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types

2016-06-27 Thread Ashish Singh
e a `server` package > in a `clients` jar, but that is just making explicit what is happening > either way (we are adding a server-only interface to the `clients` jar). > > Thoughts? > > Ismael > > On Fri, Apr 22, 2016 at 10:56 PM, Ashish Singh > wrote: > > > He

[jira] [Created] (KAFKA-3896) Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations

2016-06-23 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-3896: - Summary: Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations Key: KAFKA-3896 URL: https://issues.apache.org/jira/browse/KAFKA-3896

[jira] [Assigned] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected

2016-06-23 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh reassigned KAFKA-3822: - Assignee: Ashish K Singh > Kafka Consumer close() hangs indefinitely if Kafka Bro

[jira] [Commented] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected

2016-06-23 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347092#comment-15347092 ] Ashish K Singh commented on KAFKA-3822: --- Turns out KAFKA-3879 is a dup of this,

[jira] [Commented] (KAFKA-3879) KafkaConsumer with auto commit enabled gets stuck when killed after broker is dead

2016-06-23 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347069#comment-15347069 ] Ashish K Singh commented on KAFKA-3879: --- Sure [~hachikuji], linking the J

[jira] [Resolved] (KAFKA-3879) KafkaConsumer with auto commit enabled gets stuck when killed after broker is dead

2016-06-23 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh resolved KAFKA-3879. --- Resolution: Duplicate > KafkaConsumer with auto commit enabled gets stuck when killed af

[jira] [Commented] (KAFKA-3879) KafkaConsumer with auto commit enabled gets stuck when killed after broker is dead

2016-06-22 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15345609#comment-15345609 ] Ashish K Singh commented on KAFKA-3879: --- [~hachikuji] yeah KAFKA-3822 is poin

[jira] [Updated] (KAFKA-3849) Avoid polling every second in MirrorMaker if no data is available.

2016-06-20 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3849: -- Summary: Avoid polling every second in MirrorMaker if no data is available. (was: Make

[jira] [Commented] (KAFKA-3879) KafkaConsumer with auto commit enabled gets stuck when killed after broker is dead

2016-06-20 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15340283#comment-15340283 ] Ashish K Singh commented on KAFKA-3879: --- [~hachikuji] did you guys ever hit thi

[jira] [Created] (KAFKA-3879) KafkaConsumer with auto commit enabled gets stuck when killed after broker is dead

2016-06-20 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-3879: - Summary: KafkaConsumer with auto commit enabled gets stuck when killed after broker is dead Key: KAFKA-3879 URL: https://issues.apache.org/jira/browse/KAFKA-3879

[jira] [Updated] (KAFKA-3879) KafkaConsumer with auto commit enabled gets stuck when killed after broker is dead

2016-06-20 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3879: -- Affects Version/s: 0.10.0.0 > KafkaConsumer with auto commit enabled gets stuck when kil

[jira] [Updated] (KAFKA-3879) KafkaConsumer with auto commit enabled gets stuck when killed after broker is dead

2016-06-20 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3879: -- Fix Version/s: 0.10.0.1 > KafkaConsumer with auto commit enabled gets stuck when killed af

[jira] [Updated] (KAFKA-3849) Make consumer poll time in MirrorMaker configurable.

2016-06-16 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3849: -- Status: Patch Available (was: Open) > Make consumer poll time in MirrorMaker configura

[jira] [Created] (KAFKA-3849) Make consumer poll time in MirrorMaker configurable.

2016-06-15 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-3849: - Summary: Make consumer poll time in MirrorMaker configurable. Key: KAFKA-3849 URL: https://issues.apache.org/jira/browse/KAFKA-3849 Project: Kafka Issue

[jira] [Updated] (KAFKA-3400) Topic stop working / can't describe topic

2016-06-15 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3400: -- Resolution: Cannot Reproduce Status: Resolved (was: Patch Available) Resolving this as

Re: [VOTE] 0.10.0.0 RC6

2016-05-20 Thread Ashish Singh
> >> > > > > > >> > > > > Kafka's KEYS file containing PGP keys we use to sign the > release: > >> > > > > http://kafka.apache.org/KEYS > >> > > > > > >> > > > > * Release artifacts to be voted upon (source and binary): > >> > > > > http://home.apache.org/~gwenshap/0.10.0.0-rc6/ > >> > > > > > >> > > > > * Maven artifacts to be voted upon: > >> > > > > https://repository.apache.org/content/groups/staging/ > >> > > > > > >> > > > > * java-doc > >> > > > > http://home.apache.org/~gwenshap/0.10.0.0-rc6/javadoc/ > >> > > > > > >> > > > > * tag to be voted upon (off 0.10.0 branch) is the 0.10.0.0 tag: > >> > > > > > >> > > > > > >> > > > >> > > >> > > https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=065899a3bc330618e420673acf9504d123b800f3 > > >> > > > > > >> > > > > * Documentation: > >> > > > > http://kafka.apache.org/0100/documentation.html > >> > > > > > >> > > > > * Protocol: > >> > > > > http://kafka.apache.org/0100/protocol.html > >> > > > > > >> > > > > /** > >> > > > > > >> > > > > Thanks, > >> > > > > > >> > > > > Gwen > >> > > > > > >> > > > >> > > >> > > >> > > >> > -- > >> > -- Guozhang > >> > > >> > >> > >> > >> -- > >> Thanks, > >> Ewen > >> > > > > > > -- Ashish 🎤h

[jira] [Updated] (KAFKA-3699) Update protocol page on website to explain how KIP-35 should be used

2016-05-19 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3699: -- Status: Patch Available (was: Open) > Update protocol page on website to explain how KIP

[jira] [Resolved] (KAFKA-3724) Replace inter.broker.protocol.version with KIP-35 based version detection

2016-05-19 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh resolved KAFKA-3724. --- Resolution: Duplicate Assignee: Ashish K Singh Closing as duplicate of KAFKA-3308 and

[jira] [Updated] (KAFKA-3308) Use ProtocolVersion during rolling upgrades to decide on a mutually agreed protocol version between brokers, eliminating the need of inter.broker.protocol.version.

2016-05-19 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3308: -- Description: inter.broker.protocol.version configuration was nice for few releases, but it is

[jira] [Commented] (KAFKA-3699) Update protocol page on website to explain how KIP-35 should be used

2016-05-16 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15285135#comment-15285135 ] Ashish K Singh commented on KAFKA-3699: --- I will have a patch ready hopefully by

[jira] [Assigned] (KAFKA-3699) Update protocol page on website to explain how KIP-35 should be used

2016-05-10 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh reassigned KAFKA-3699: - Assignee: Ashish K Singh > Update protocol page on website to explain how KIP-35 sho

[jira] [Commented] (KAFKA-3699) Update protocol page on website to explain how KIP-35 should be used

2016-05-10 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279429#comment-15279429 ] Ashish K Singh commented on KAFKA-3699: --- [~ijuma] I will take a crack at it. I

Re: [VOTE] KIP-50: Move Authorizer to o.a.k.common package - Round 2

2016-05-02 Thread Ashish Singh
KIP-50 has passed with +6 (binding) and +3 (non-binding). Thanks everyone for reviews and votes! On Sun, May 1, 2016 at 4:08 PM, Don Bosco Durai wrote: > +1 (non binding) > > > > > On 4/28/16, 7:47 AM, "Jun Rao" wrote: > > >Ashish, > > > >Tha

Re: KAFKA-1981 Make log compaction point configurable

2016-04-27 Thread Ashish Singh
ttps://issues.apache.org/jira/browse/KAFKA-1981 > > Could someone please add it to the KIP page or grant me the mojo to do it > myself? > > Thanks, > > Eric > -- Regards, Ashish

[jira] [Resolved] (KAFKA-3469) kafka-topics lock down znodes with user principal when zk security is enabled.

2016-04-27 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh resolved KAFKA-3469. --- Resolution: Information Provided Had an offline discussion with [~fpj] and it seems we can

Re: [ANNOUNCE] New committer: Ismael Juma

2016-04-25 Thread Ashish Singh
the board from mailing lists, JIRA, code > reviews > > and helping us move to GitHub pull requests to contributing features, bug > > fixes and code and documentation improvements. > > > > Thank you for your contribution and welcome to Apache Kafka, Ismael! > > > > -- > > Thanks, > > Neha > > > > > > -- > -- Guozhang > -- Ashish 🎤h

[jira] [Updated] (KAFKA-3621) Add tests for ApiVersionRequest/Response

2016-04-25 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3621: -- Priority: Critical (was: Major) > Add tests for ApiVersionRequest/Respo

[jira] [Updated] (KAFKA-3621) Add tests for ApiVersionRequest/Response

2016-04-25 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3621: -- Fix Version/s: 0.10.0.0 > Add tests for ApiVersionRequest/Respo

[jira] [Updated] (KAFKA-3621) Add tests for ApiVersionRequest/Response

2016-04-25 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3621: -- Affects Version/s: 0.10.0.0 > Add tests for ApiVersionRequest/Respo

[jira] [Created] (KAFKA-3621) Add tests for ApiVersionRequest/Response

2016-04-25 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-3621: - Summary: Add tests for ApiVersionRequest/Response Key: KAFKA-3621 URL: https://issues.apache.org/jira/browse/KAFKA-3621 Project: Kafka Issue Type: Task

[jira] [Updated] (KAFKA-3620) Clean up Protocol class.

2016-04-25 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3620: -- Description: This came up on PR of KAFKA-3307. Below is excerpt. {quote} With the versioning

[jira] [Created] (KAFKA-3620) Clean up Protocol class.

2016-04-25 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-3620: - Summary: Clean up Protocol class. Key: KAFKA-3620 URL: https://issues.apache.org/jira/browse/KAFKA-3620 Project: Kafka Issue Type: Improvement

Re: [VOTE] KIP-35: Retrieve protocol version - Round 2

2016-04-25 Thread Ashish Singh
est knowledge of the client at the time of development (or > > > > alternatively by configuration)." > > > > > > > > I still think that the mention of both 0.9.0 and 0.9.1 is confusing > and > > > > it's not clear if we need it for

[VOTE] KIP-50: Move Authorizer to o.a.k.common package - Round 2

2016-04-25 Thread Ashish Singh
om/apache/kafka/pull/861>. The vote will run for 72 hours and I would like to start it with my +1 (non-binding). ​ -- Regards, Ashish

[jira] [Updated] (KAFKA-3606) Traverse CLASSPATH during herder start to list connectors

2016-04-24 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3606: -- Fix Version/s: (was: 0.10.1.0) 0.10.0.0 > Traverse CLASSPATH dur

Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types

2016-04-22 Thread Ashish Singh
>> current approach I think the authorizer stuff would be most consistent > as a > >> public package in common. It is true that this means you build against > more > >> stuff then needed but I'm not sure this has any negative implications in > >> practice. > >

Re: [VOTE] KIP-35: Retrieve protocol version - Round 2

2016-04-22 Thread Ashish Singh
Hello Jun, On Fri, Apr 22, 2016 at 11:31 AM, Jun Rao wrote: > Ashish, > > Just a couple of clarifications. > > 1. In ApiVersionRequest, we should get rid of ApiKeys since the request has > an empty body, right? > Yes. > > 2. In ApiVersionResponse, we should list E

[VOTE] KIP-35: Retrieve protocol version - Round 2

2016-04-21 Thread Ashish Singh
te will run for 72 hours and I would like to start it with my +1 (non-binding). ​ -- Regards, Ashish

  1   2   3   4   5   6   7   8   9   10   >