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

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

[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: Ka

[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 > java.

[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&focusedCommentId=16636250#comment-16636250 ] Robert Yokota commented on KAFKA-7476: -- Here is a more detailed stack trace: {code:j

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

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

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

[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&focusedCommentId=16618240#comment-16618240 ] Robert Yokota commented on KAFKA-7370: -- Recommendation was to add a DirectoryConfigP

[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: Impr

[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&focusedCommentId=16571135#comment-16571135 ] Robert Yokota commented on KAFKA-7242: -- [~bsiamionau], thanks for finding and loggin

[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&focusedCommentId=16566918#comment-16566918 ] Robert Yokota commented on KAFKA-7225: -- Thanks [~nachomdo]!  Again, I really appreci

[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&focusedCommentId=16566913#comment-16566913 ] Robert Yokota commented on KAFKA-7225: -- If you want, I can still close my PR so you

[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&focusedCommentId=16566907#comment-16566907 ] Robert Yokota commented on KAFKA-7225: -- Hi [~nachomdo], thanks for finding and loggi

[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&focusedCommentId=16515017#comment-16515017 ] Robert Yokota edited comment on KAFKA-7068 at 6/17/18 7:20 AM:

[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&focusedCommentId=16515017#comment-16515017 ] Robert Yokota commented on KAFKA-7068: -- Here is a PR to fix this: https://issues.apa

[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&focusedCommentId=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&focusedCommentId=16513966#comment-16513966 ] Robert Yokota commented on KAFKA-7048: -- Yes, this is a blocker.  Suggested a small c

[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&focusedCommentId=16472374#comment-16472374 ] Robert Yokota edited comment on KAFKA-6566 at 5/11/18 6:04 PM: -

[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&focusedCommentId=16472374#comment-16472374 ] Robert Yokota commented on KAFKA-6566: -- I've just started looking at this, but it loo

[jira] [Updated] (KAFKA-6894) Improve error message when connecting processor with a global store

[ https://issues.apache.org/jira/browse/KAFKA-6894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota updated KAFKA-6894: - Description: I was trying to access a store from a {{GlobalKTable}} in {{KStream.transform()}}, b

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

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

[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&focusedCommentId=16450299#comment-16450299 ] Robert Yokota edited comment on KAFKA-6142 at 4/24/18 5:59 PM: -

[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&focusedCommentId=16450299#comment-16450299 ] Robert Yokota commented on KAFKA-6142: -- We might also want variables to be able to re

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

[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-6503: Assignee: Robert Yokota > Connect: Plugin scan is very slow > -

[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&focusedCommentId=16363139#comment-16363139 ] Robert Yokota commented on KAFKA-6503: -- With my setup where plugin.path was pointing

[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&focusedCommentId=16358714#comment-16358714 ] Robert Yokota commented on KAFKA-6407: -- Yes, I believe so.  I'll resolve it as duplic

[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&focusedCommentId=16355785#comment-16355785 ] Robert Yokota commented on KAFKA-6504: -- [~steff1193], it's not just the metric name c

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

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