d fallback to backslash to escape
> back-ticks?
>
> What do you think?
>
> Many thanks,
> Jorge.
>
>
> On Wed, 20 Jul 2022 at 23:03, Robert Yokota wrote:
>
> > Hi,
> >
> > I'm late to this thread, but would like to comment on the double
> dot/dou
Hi,
I'm late to this thread, but would like to comment on the double dot/double
asterisk syntax.
Unfortunately double dot is often used in JSON Path as a descendant
selector, see https://www.ietf.org/id/draft-ietf-jsonpath-base-05.html
I think a better notation would be to use backticks to
Robert Yokota created KAFKA-8404:
Summary: Authorization header is not passed in Connect when
forwarding REST requests
Key: KAFKA-8404
URL: https://issues.apache.org/jira/browse/KAFKA-8404
Project
Thanks for the great KIP Konstantine!
+1 (non-binding)
Robert
On Thu, Mar 7, 2019 at 2:56 PM Guozhang Wang wrote:
> Thanks Konstantine, I've read the updated section on
>
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-415%3A+Incremental+Cooperative+Rebalancing+in+Kafka+Connect
> and
[
https://issues.apache.org/jira/browse/KAFKA-7512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Yokota resolved KAFKA-7512.
--
Resolution: Duplicate
> java.lang.ClassCastException: java.util.Date cannot be c
Robert Yokota created KAFKA-7476:
Summary: SchemaProjector is not properly handling Date-based
logical types
Key: KAFKA-7476
URL: https://issues.apache.org/jira/browse/KAFKA-7476
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Yokota resolved KAFKA-7370.
--
Resolution: Won't Do
> Enhance FileConfigProvider to read a direct
r, adding this
> behavior to FileConfigProvider seems like it might give someone who
> accidentally configures a directory rather than a file a nasty surprise.
> How about adding a DirectoryConfigProvider which adds this behavior?
>
> best,
> Colin
>
>
> On Tue, Sep 4, 2018, a
wrote:
> > > Hi Konstantine,
> > >
> > > Sounds reasonable to me too.
> > >
> > > Regards,
> > >
> > > Rajini
> > >
> > > On Mon, Jun 11, 2018 at 7:55 PM, Robert Yokota
> > wrote:
> > >
>
Robert Yokota created KAFKA-7370:
Summary: Enhance FileConfigProvider to read a directory
Key: KAFKA-7370
URL: https://issues.apache.org/jira/browse/KAFKA-7370
Project: Kafka
Issue Type
ption.
>
> - Konstantine
>
>
>
> On Wed, May 16, 2018 at 10:33 AM, Rajini Sivaram
> wrote:
>
> > Thanks for the update, Robert. Looks good to me.
> >
> > Regards,
> >
> > Rajini
> >
> > On Wed, May 16, 2018 at 4:43 PM, Robert
297: Externalizing
> Secrets
> > > for Connect Configurations
> > > Thanks Robert, this looks great
> > >
> > > +1 (non-binding)
> > >
> > > On Thu, May 17, 2018 at 5:35 PM, Colin McCabe <cmcc...@apache.org>
> > wrote:
> &g
] KIP-297: Externalizing Secrets
> > for Connect Configurations
> > Thanks Robert, this looks great
> >
> > +1 (non-binding)
> >
> > On Thu, May 17, 2018 at 5:35 PM, Colin McCabe <cmcc...@apache.org>
> wrote:
> >
> > > Thanks, Robert!
> &
Hi Colin,
I've changed the KIP to have a composite object returned from get(). It's
probably the most straightforward option. Please let me know if you have
any other concerns.
Thanks,
Robert
On Thu, May 17, 2018 at 11:44 AM, Robert Yokota <rayok...@gmail.com> wrote:
>
>
> H
eys after a certain amount of time.
>
> As an aside, what does a "lease duration" mean for a configuration key?
> Does that mean Vault will reject changes to the configuration key if I try
> to make them within the lease duration? Or is this like a period after
> which a
gt;
> On Wed, May 16, 2018, at 19:13, Robert Yokota wrote:
> > Hi Colin,
> >
> > Good questions.
> >
> >
> > > As a clarification about the indirections, what if I have the
> > > connect> configuration key foo set up as ${vault:bar}, and in V
; >// that a future change is anticipated (such as a lease duration)
> >void onChange(String path, Map<String, String> values, int delayMs);
>
> Do we really need delayMs? It seems like if you get a callback with
> delayMs set, you don't know what the new values w
Hello everyone,
After a good round of discussions with excellent feedback and no major
objections, I would like to start a vote on KIP-297 to externalize secrets
from Kafka Connect configurations. My thanks in advance!
KIP: <
Couldn't ConfigData be an interface that just returns a map of
>key-value pairs. Providers that return metadata could extend it to
> provide
>metadata in a meaningful format instead of Map<String, String>.
>3. For ZK, we would use ConfigProvider.get() without `keys`
ticate to the remote systems anyway), but regardless, that class
> should be useful at least in some minimal sense if not more than that. See
> https://github.com/apache/kafka/pull/4994.
>
> Ron
>
> Ron
>
> On Tue, May 15, 2018 at 8:01 PM, Robert Yokota
mer: do we need to include all this code in
> the KIP? Seems like an implementation detail.
>
> > Other connectors such as the S3 connector are tightly coupled with a
> particular secret manager, and may
> > wish to handle rotation on their own.
>
> Is there a way to
Robert Yokota created KAFKA-6894:
Summary: Cannot access GlobalKTable store from KStream.transform()
Key: KAFKA-6894
URL: https://issues.apache.org/jira/browse/KAFKA-6894
Project: Kafka
/4990/files.
I also added an example of a FileConfigProvider to the KIP.
Thanks,
Robert
On Wed, May 9, 2018 at 10:04 AM, Robert Yokota <rayok...@gmail.com> wrote:
> Hi Magesh,
>
> Thanks for the feedback!
>
> I will put together a PR to demonstrate what the implementat
> > all the indirect references resolved. If so, trying to understand
> > the intent of the config() in SourceTaskContext and the SinkTaskContext
> > 3. What if the provider itself needs some kind of secrets to be
> configured
> > to connect to it? I assume that's out of scope for this
kind of secrets to be configured
> to connect to it? I assume that's out of scope for this proposal but wanted
> to clarify it.
>
> Thanks
> Magesh
>
> On Tue, May 8, 2018 at 1:52 PM, Robert Yokota <rayok...@gmail.com> wrote:
>
> > Hi,
> >
> > I woul
Hi,
I would like to start a discussion for KIP-297 to externalize secrets from
Kafka Connect configurations. Any feedback is appreciated.
<
https://cwiki.apache.org/confluence/display/KAFKA/KIP-297%3A+Externalizing+Secrets+for+Connect+Configurations
>
JIRA:
Robert Yokota created KAFKA-6886:
Summary: Externalize Secrets for Kafka Connect Configurations
Key: KAFKA-6886
URL: https://issues.apache.org/jira/browse/KAFKA-6886
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-6407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Yokota resolved KAFKA-6407.
--
Resolution: Duplicate
> Sink task metrics are the same for all connect
[
https://issues.apache.org/jira/browse/KAFKA-2925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Yokota resolved KAFKA-2925.
--
Resolution: Cannot Reproduce
I wasn't able to reproduce the NPE and by reviewing the code
Hi,
Can someone please add me to the contributor list? I want to assign
KAFKA-2925 to myself so I can close it out.
Thanks,
Robert Yokota
30 matches
Mail list logo
