David Jacot created KAFKA-8901:
--
Summary: Extend consumer group command to use the new Admin API to
delete consumer offsets
Key: KAFKA-8901
URL: https://issues.apache.org/jira/browse/KAFKA-8901
Project
Hey,
I have done this before with this proxy:
https://github.com/grepplabs/kafka-proxy#connect-to-kafka-through-socks5-proxy-example
You can spin up a socks proxy when you ssh to your jumphost (-D argument if
not mistaken) and
configure the proxy as described in the readme.
It is good for dev an
r
> don't set the version at all (for compatibility). So the version/type has
> to be mutable and added after the TCP connection itself is established.
>
> best,
> Colin
>
>
> On Mon, Sep 9, 2019, at 06:11, David Jacot wrote:
> > Hi Gwen,
> >
> > The
in the request at all, so there is no need for the broker to know exactly
> how long the supplied request header is. (This assumes that the first 4
> fields of the request header will never change, which seems like a
> reasonable assumption...)
> >
> > best,
> > C
n evolve the
> request header by adding tagged fields...
> >
> > Another option is to fall all the way back to version 0 when the broker
> doesn't understand the client's supplied version. Version 0 had no content
> in the request at all, so there is no need for the b
Hi Manikumar,
Could we add KIP-511 to the plan? I think it will make it.
Thanks,
David
On Tue, Aug 27, 2019 at 5:32 PM Manikumar wrote:
> Hi all,
>
> I put together a draft release plan with Oct 2019 as the release month and
> a list of KIPs that have already been voted:
>
> https://cwiki.apac
Hi all,
While implementing the KIP, I have realized that a new error code and
exception is required to notify the caller that offsets of a topic can not
be deleted because the group is actively subscribed to the topic.
I would like to know if there are any concerns with these changes before
updat
Request, it
> doesn't make sense to fall back all the way to 0 if the broker supports 1
> (for example).
>
> If you agree, it would be good to spell this out in the KIP, so that if we
> want to add more things to the response, we can, without losing them each
> time the c
+1 (non-binding)
Thank for the KIP. Great addition to the Kafka protocol!
Best,
David
Le mar. 3 sept. 2019 à 19:17, Colin McCabe a écrit :
> Hi all,
>
> I'd like to start the vote for KIP-482: The Kafka Protocol should Support
> Optional Tagged Fields.
>
> KIP:
> https://cwiki.apache.org/confl
:31 AM David Jacot wrote:
> Hi Magnus,
>
> Thank you for your feedback. Please, find my comments below.
>
> 1. I thought that the clientId was meant for this purpose (providing
> information about the application). Is there a gap I don't see?
>
> 2. I have put two f
David Jacot created KAFKA-8855:
--
Summary: Collect and Expose Client's Name and Version in the
Brokers
Key: KAFKA-8855
URL: https://issues.apache.org/jira/browse/KAFKA-8855
Project: Kafka
broker name and version to the
> > ApiVersionResponse?
> > While an application must not use this information to detect features (Hi
> > Jay!), it is good for troubleshooting
> > and providing more meaningful logs to the client user in case a feature
> > (based on
lin
> >
> >
> > On Wed, Aug 21, 2019, at 12:05, Adam Bellemare wrote:
> > > +users mailing list
> > >
> > > David,
> > >
> > > I don't think I really understand your email. Are you saying that this
> > can
> > > alread
-version?
>
> 1.
> https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/KafkaRequestHandler.scala#L231
>
> Thanks,
> Satish.
>
>
>
>
> On Wed, Aug 21, 2019 at 5:33 PM David Jacot wrote:
> >
> > Hi all,
> >
> > I would lik
Hi all,
I would like to start a discussion for KIP-511:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-511%3A+Collect+and+Expose+Client%27s+Name+and+Version+in+the+Brokers
Let me know what you think.
Best,
David
Hello,
It would be better to ask such question on the user mailing list.
The reason is that the group is created automatically when a consumer
joins it. It is not created explicitly so it can be restricted.
In your case, you could setup a ACL to authorize the application to only
use the group yo
+1 (non-binding)
Thanks for the KIP!
Best,
David
On Tue, Aug 20, 2019 at 7:55 PM Jason Gustafson wrote:
> Hi All,
>
> I'd like to start a vote on KIP-352, which is a follow-up to KIP-455 to fix
> a long-known shortcoming of URP reporting and to improve reassignment
> monitoring:
>
> https://cw
Thank you, Bill!
Le mar. 20 août 2019 à 16:45, Bill Bejeck a écrit :
> Hi David,
>
> You're all set now.
>
> -Bill
>
> On Tue, Aug 20, 2019 at 10:04 AM David Jacot wrote:
>
> > Hi Bill,
> >
> > Sure. It is dajac.
> >
> > Thanks,
&g
Hi Bill,
Sure. It is dajac.
Thanks,
David
On Tue, Aug 20, 2019 at 3:55 PM Bill Bejeck wrote:
> Hi David,
>
> Sure thing, can you share your wiki username?
>
> Thanks,
> Bill
>
> On Tue, Aug 20, 2019 at 9:53 AM David Jacot wrote:
>
> > Hey,
> >
>
Hey,
I would like to create a KIP but I don't have the permission yet. Could
someone grant me the relevant permission to the wiki?
Thanks,
David
+1 (non-binding)
Thanks for the KIP, Rajini.
Best,
David
On Sun, Aug 18, 2019 at 9:42 PM Mickael Maison
wrote:
> +1 (non binding)
> Thanks for the KIP!
>
> On Sun, Aug 18, 2019 at 3:05 PM Ron Dagostino wrote:
> >
> > +1 (non-binding)
> >
> > Thanks, Rajini.
> >
> > Ron
> >
> > On Sat, Aug 17,
nging
> > > the protocol on the wire.
> > >
> > > Can an Optional field have a struct type which internally contains an
> array
> > > field at any level?
> > >
> > > Thanks,
> > > Satish.
> > >
> > >
> > >
+1 (non-binding)
Thanks for the KIP! Simple yet very useful.
Best,
David
On Wed, Aug 14, 2019 at 9:24 AM Robert Barrett
wrote:
> +1 (non-binding)
>
> This will be good to have, thanks David!
>
> Bob
>
> On Wed, Aug 14, 2019 at 6:08 AM Mickael Maison
> wrote:
>
> > +1 non binding
> > Thank you
Hi Colin,
Thank you for the KIP! Things are well explained!. It is huge improvement
for the Kafka protocol. I have few comments on the proposal:
1. The interleaved tag/length header sounds like a great optimisation as it
would be shorter on average. The downside, as
you already pointed out, is th
ag`. It is provided to improve
> audit logging in the authorizer. The enum values have javadoc which
> indicate how the authorization result is used in each of the modes to
> enable authorizers to log audit messages at the right severity level.
>
> Regards,
>
> Rajini
>
> On
Hi Rajini,
Thank you for the KIP. Overall, it looks good to me. I have few
questions/suggestions:
1. It is hard to grasp what `Action#count` is for. I guess I understand
where you want to go with it but it took me a while to figure it out.
Perhaps, we could come up with a better name than `count`
[
https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2066 stopped by David Jacot.
--
> Replace FetchRequest / FetchResponse with th
[
https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2066:
---
Assignee: (was: David Jacot)
> Replace FetchRequest / FetchResponse with th
[
https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571702#comment-15571702
]
David Jacot commented on KAFKA-2066:
Unfortunately, I won't have time in
[
https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112619#comment-15112619
]
David Jacot commented on KAFKA-2066:
[~becket_qin] That makes sense. I'll ta
[
https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112045#comment-15112045
]
David Jacot commented on KAFKA-2066:
[~becket_qin], indeed replacing MessageSet
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2071:
---
Status: Patch Available (was: In Progress)
> Replace Produce Request/Response with th
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2071:
---
Status: In Progress (was: Patch Available)
> Replace Produce Request/Response with th
[
https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15107051#comment-15107051
]
David Jacot commented on KAFKA-2066:
[~ijuma],
- Inheritance might not be the
[
https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15104883#comment-15104883
]
David Jacot commented on KAFKA-2066:
In the current implementation, FetchResp
[
https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2066 started by David Jacot.
--
> Replace FetchRequest / FetchResponse with th
[
https://issues.apache.org/jira/browse/KAFKA-3098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-3098:
---
Assignee: David Jacot
Status: Patch Available (was: Open)
> "partition.assignment.
[
https://issues.apache.org/jira/browse/KAFKA-2758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15095678#comment-15095678
]
David Jacot commented on KAFKA-2758:
[~guozhang] I'd like to dive int
[
https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-2066:
--
Assignee: David Jacot
> Replace FetchRequest / FetchResponse with th
[
https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-3085:
---
Status: Patch Available (was: In Progress)
> BrokerChangeListener computes inconsistent live/d
[
https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-3085:
---
Status: In Progress (was: Patch Available)
> BrokerChangeListener computes inconsistent live/d
[
https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15093334#comment-15093334
]
David Jacot commented on KAFKA-3085:
[~junrao] No worries. I'll update it ac
[
https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-3085:
---
Status: Patch Available (was: Open)
> BrokerChangeListener computes inconsistent live/dead bro
[
https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-3085:
--
Assignee: David Jacot
> BrokerChangeListener computes inconsistent live/dead broker l
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2072:
---
Status: Patch Available (was: In Progress)
> Add StopReplica request/response
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2072:
---
Status: In Progress (was: Patch Available)
> Add StopReplica request/response
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2072:
---
Status: Patch Available (was: In Progress)
> Add StopReplica request/response
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716229#comment-14716229
]
David Jacot commented on KAFKA-2072:
[~ijuma] Do you also need rest of this one
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reopened KAFKA-2072:
Reopen this JIRA as https://github.com/apache/kafka/pull/170 adds StopReplica
request/response to
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2072 started by David Jacot.
--
> Add StopReplica request/response to o.a.k.common.requests and replace the
>
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14710629#comment-14710629
]
David Jacot commented on KAFKA-2072:
Moved it back to "in progress
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2072 started by David Jacot.
--
> Add StopReplica request/response to o.a.k.common.requests and replace the
>
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2072:
---
Status: Open (was: Patch Available)
> Add StopReplica request/response to o.a.k.common.requests
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14710622#comment-14710622
]
David Jacot commented on KAFKA-2071:
I have merged trunk in the PR and adapted i
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699279#comment-14699279
]
David Jacot commented on KAFKA-2072:
As discussed with [~ijuma], it would be be
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2072:
---
Status: Patch Available (was: Open)
> Add StopReplica request/response to o.a.k.common.requests
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-2072:
--
Assignee: David Jacot
> Add StopReplica request/response to o.a.k.common.requests and repl
[
https://issues.apache.org/jira/browse/KAFKA-2073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14693859#comment-14693859
]
David Jacot commented on KAFKA-2073:
[~abiletskyi] Are you still working on this
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14693855#comment-14693855
]
David Jacot commented on KAFKA-2071:
[~gwenshap] Could you review this one when
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2071:
---
Status: Patch Available (was: In Progress)
> Replace Produce Request/Response with th
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14681274#comment-14681274
]
David Jacot commented on KAFKA-2071:
I just updated the PR. Now, ProducerRequest
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14662025#comment-14662025
]
David Jacot commented on KAFKA-2071:
I have looked at the producer and I think
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654811#comment-14654811
]
David Jacot commented on KAFKA-2071:
Indeed, because kafka.api.ProduceReques
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654799#comment-14654799
]
David Jacot commented on KAFKA-2071:
I thought that the intent was to only rep
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2071:
---
Status: Patch Available (was: Open)
> Replace Produce Request/Response with th
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-2071:
--
Assignee: David Jacot
> Replace Produce Request/Response with th
[
https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644699#comment-14644699
]
David Jacot commented on KAFKA-2100:
[~gwenshap] Could you review this one when
[
https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2100:
---
Status: Patch Available (was: Open)
> Client Error doesn't preserve or display original serv
[
https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14642296#comment-14642296
]
David Jacot commented on KAFKA-2100:
Thank you for your feedback. I just upload
[
https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2100:
---
Attachment: KAFKA-2100-2.patch
> Client Error doesn't preserve or display original server er
[
https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14640941#comment-14640941
]
David Jacot commented on KAFKA-2100:
I think that UNKNOWN must be kept in the Er
[
https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2100:
---
Attachment: KAFKA-2100-1.patch
> Client Error doesn't preserve or display original server er
[
https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14640448#comment-14640448
]
David Jacot commented on KAFKA-2100:
I have looked at how Errors are used in the
[
https://issues.apache.org/jira/browse/KAFKA-2357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14639117#comment-14639117
]
David Jacot edited comment on KAFKA-2357 at 7/23/15 5:0
[
https://issues.apache.org/jira/browse/KAFKA-2357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14639117#comment-14639117
]
David Jacot commented on KAFKA-2357:
Fixed documentation for 0.8.2 and 0
[
https://issues.apache.org/jira/browse/KAFKA-2357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2357:
---
Assignee: David Jacot
Fix Version/s: 0.8.3
0.8.1.2
Status
[
https://issues.apache.org/jira/browse/KAFKA-2357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-2357:
---
Attachment: KAFKA-2357-1.patch
> Update zookeeper.connect description in Kafka documentat
[
https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14633066#comment-14633066
]
David Jacot commented on KAFKA-2100:
[~gwenshap] Are you working on this one?
Hi Kafka team,
First of all, thank you for the awesome work! Kafka is really an awesome
piece of technology. I have been using it since you open sourced it and
would like to contribute to it.
Could you please add me to the contributor list?
Thanks!
David Jacot
901 - 979 of 979 matches
Mail list logo
