[jira] [Assigned] (KAFKA-8591) NPE when reloading connector configuration using WorkerConfigTransformer

[ https://issues.apache.org/jira/browse/KAFKA-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-8591: Assignee: Robert Yokota > NPE when reloading connector configuration using

[jira] [Updated] (KAFKA-8404) Authorization header is not passed in Connect when forwarding REST requests

[ https://issues.apache.org/jira/browse/KAFKA-8404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota updated KAFKA-8404: - Affects Version/s: 2.0.0 > Authorization header is not passed in Connect when forwarding REST

[jira] [Created] (KAFKA-8404) Authorization header is not passed in Connect when forwarding REST requests

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:

[jira] [Assigned] (KAFKA-7620) ConfigProvider is broken for KafkaConnect when TTL is not null

[ https://issues.apache.org/jira/browse/KAFKA-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-7620: Assignee: Robert Yokota > ConfigProvider is broken for KafkaConnect when TTL is not null

[jira] [Resolved] (KAFKA-7512) java.lang.ClassCastException: java.util.Date cannot be cast to java.lang.Number

[ 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 cast to >

[jira] [Commented] (KAFKA-7476) SchemaProjector is not properly handling Date-based logical types

[ https://issues.apache.org/jira/browse/KAFKA-7476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636250#comment-16636250 ] Robert Yokota commented on KAFKA-7476: -- Here is a more detailed stack trace: {code:java} Caused by:

[jira] [Updated] (KAFKA-7476) SchemaProjector is not properly handling Date-based logical types

[ https://issues.apache.org/jira/browse/KAFKA-7476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota updated KAFKA-7476: - Description: SchemaProjector is not properly handling Date-based logical types.  An exception

[jira] [Resolved] (KAFKA-7370) Enhance FileConfigProvider to read a directory

[ 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 directory >

[jira] [Commented] (KAFKA-7370) Enhance FileConfigProvider to read a directory

[ https://issues.apache.org/jira/browse/KAFKA-7370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16618240#comment-16618240 ] Robert Yokota commented on KAFKA-7370: -- Recommendation was to add a DirectoryConfigProvider instead.

[jira] [Created] (KAFKA-7370) Enhance FileConfigProvider to read a directory

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:

[jira] [Commented] (KAFKA-7242) Externalized secrets are revealed in task configuration

[ https://issues.apache.org/jira/browse/KAFKA-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571135#comment-16571135 ] Robert Yokota commented on KAFKA-7242: -- [~bsiamionau], thanks for finding and logging this issue.  

[jira] [Assigned] (KAFKA-7242) Externalized secrets are revealed in task configuration

[ https://issues.apache.org/jira/browse/KAFKA-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-7242: Assignee: Robert Yokota > Externalized secrets are revealed in task configuration >

[jira] [Commented] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566913#comment-16566913 ] Robert Yokota commented on KAFKA-7225: -- If you want, I can still close my PR so you can look into

[jira] [Commented] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566907#comment-16566907 ] Robert Yokota commented on KAFKA-7225: -- Hi [~nachomdo], thanks for finding and logging this issue.

[jira] [Assigned] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-7225: Assignee: Robert Yokota > Kafka Connect ConfigProvider not invoked before validation >

[jira] [Comment Edited] (KAFKA-7068) ConfigTransformer doesn't handle null values

[ https://issues.apache.org/jira/browse/KAFKA-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515017#comment-16515017 ] Robert Yokota edited comment on KAFKA-7068 at 6/17/18 7:20 AM: --- Here is a

[jira] [Commented] (KAFKA-7068) ConfigTransformer doesn't handle null values

[ https://issues.apache.org/jira/browse/KAFKA-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515017#comment-16515017 ] Robert Yokota commented on KAFKA-7068: -- Here is a PR to fix this: 

[jira] [Comment Edited] (KAFKA-7048) NPE when creating connector

[ https://issues.apache.org/jira/browse/KAFKA-7048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513966#comment-16513966 ] Robert Yokota edited comment on KAFKA-7048 at 6/15/18 5:45 PM: ---

[jira] [Commented] (KAFKA-7048) NPE when creating connector

[ https://issues.apache.org/jira/browse/KAFKA-7048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513966#comment-16513966 ] Robert Yokota commented on KAFKA-7048: -- Yes, this is a blocker.  Suggested a small change to the

[jira] [Comment Edited] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472374#comment-16472374 ] Robert Yokota edited comment on KAFKA-6566 at 5/11/18 6:04 PM: --- I've just

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472374#comment-16472374 ] Robert Yokota commented on KAFKA-6566: -- I've just started looking at this, but it looks like the

[jira] [Created] (KAFKA-6894) Cannot access GlobalKTable store from KStream.transform()

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

[jira] [Created] (KAFKA-6886) Externalize Secrets for Kafka Connect Configurations

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

[jira] [Comment Edited] (KAFKA-6142) Connect worker configurations and connector configurations should accept environment variables

[ https://issues.apache.org/jira/browse/KAFKA-6142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450299#comment-16450299 ] Robert Yokota edited comment on KAFKA-6142 at 4/24/18 5:59 PM: --- We might

[jira] [Commented] (KAFKA-6142) Connect worker configurations and connector configurations should accept environment variables

[ https://issues.apache.org/jira/browse/KAFKA-6142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450299#comment-16450299 ] Robert Yokota commented on KAFKA-6142: -- We might also want variables to be able to refer to

[jira] [Commented] (KAFKA-6503) Connect: Plugin scan is very slow

[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363139#comment-16363139 ] Robert Yokota commented on KAFKA-6503: -- With my setup where plugin.path was pointing to share/java,

[jira] [Resolved] (KAFKA-6407) Sink task metrics are the same for all connectors

[ 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 connectors >

[jira] [Commented] (KAFKA-6407) Sink task metrics are the same for all connectors

[ https://issues.apache.org/jira/browse/KAFKA-6407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358714#comment-16358714 ] Robert Yokota commented on KAFKA-6407: -- Yes, I believe so.  I'll resolve it as duplicate. > Sink

[jira] [Commented] (KAFKA-6504) Connect: Some per-task-metrics not working

[ https://issues.apache.org/jira/browse/KAFKA-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355785#comment-16355785 ] Robert Yokota commented on KAFKA-6504: -- [~steff1193], it's not just the metric name change.  The PR

[jira] [Assigned] (KAFKA-6504) Connect: Some per-task-metrics not working

[ https://issues.apache.org/jira/browse/KAFKA-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-6504: Assignee: Robert Yokota > Connect: Some per-task-metrics not working >

[jira] [Resolved] (KAFKA-2925) NullPointerException if FileStreamSinkTask is stopped before initialization finishes

[ 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 it

[jira] [Assigned] (KAFKA-2925) NullPointerException if FileStreamSinkTask is stopped before initialization finishes

[ https://issues.apache.org/jira/browse/KAFKA-2925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-2925: Assignee: Robert Yokota > NullPointerException if FileStreamSinkTask is stopped before