[jira] [Updated] (KAFKA-2484) Add schema projection utilities

2015-10-16 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-2484: -- Status: Patch Available (was: In Progress) > Add schema projection utilities >

[jira] [Work started] (KAFKA-2479) Add CopycatExceptions to indicate transient and permanent errors in a connector/task

2015-10-09 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2479 started by Liquan Pei. - > Add CopycatExceptions to indicate transient and permanent errors in a >

[jira] [Work started] (KAFKA-2484) Add schema projection utilities

2015-10-09 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2484 started by Liquan Pei. - > Add schema projection utilities > --- > >

[jira] [Work started] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

2015-10-09 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2480 started by Liquan Pei. - > Handle non-CopycatExceptions from SinkTasks >

[jira] [Assigned] (KAFKA-2369) Add Copycat REST API

2015-10-09 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-2369: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Add Copycat REST API >

[jira] [Assigned] (KAFKA-2479) Add CopycatExceptions to indicate transient and permanent errors in a connector/task

2015-09-28 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-2479: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Add CopycatExceptions to indicate transient

[jira] [Assigned] (KAFKA-2484) Add schema projection utilities

2015-09-28 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-2484: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Add schema projection utilities >

[jira] [Assigned] (KAFKA-2481) Allow copycat sinks to request periodic invocation of put even if no new data is available

2015-09-28 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-2481: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Allow copycat sinks to request periodic

[jira] [Commented] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

2015-09-25 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14908909#comment-14908909 ] Liquan Pei commented on KAFKA-2480: --- Can you assign this to me? > Handle non-CopycatExceptions from

[jira] [Comment Edited] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

2015-09-25 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14908909#comment-14908909 ] Liquan Pei edited comment on KAFKA-2480 at 9/26/15 12:00 AM: - Can anyone

[jira] [Assigned] (KAFKA-2375) Implement elasticsearch Copycat sink connector

2015-12-16 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-2375: - Assignee: Liquan Pei > Implement elasticsearch Copycat sink connector >

[jira] [Updated] (KAFKA-3782) Transient failure with kafkatest.tests.connect.connect_distributed_test.ConnectDistributedTest.test_bounce.clean=True

2016-06-02 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3782: -- Description: For commit 946ae60 max() arg is an empty sequence Traceback (most recent call last):

[jira] [Assigned] (KAFKA-3820) Provide utilities for tracking source offsets

2016-06-09 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3820: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Provide utilities for tracking source

[jira] [Assigned] (KAFKA-2894) WorkerSinkTask doesn't handle rewinding offsets on rebalance

2016-05-31 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-2894: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > WorkerSinkTask doesn't handle rewinding

[jira] [Created] (KAFKA-3782) Transient failure with kafkatest.tests.connect.connect_distributed_test.ConnectDistributedTest.test_bounce.clean=True

2016-06-02 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3782: - Summary: Transient failure with kafkatest.tests.connect.connect_distributed_test.ConnectDistributedTest.test_bounce.clean=True Key: KAFKA-3782 URL:

[jira] [Assigned] (KAFKA-3124) Update protocol wiki page to reflect latest request/response formats

2016-01-29 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3124: - Assignee: Liquan Pei > Update protocol wiki page to reflect latest request/response formats >

[jira] [Work started] (KAFKA-3526) REST APIs return object representation instead of string for config values, default values and recommended values

2016-04-07 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3526 started by Liquan Pei. - > REST APIs return object representation instead of string for config values, >

[jira] [Updated] (KAFKA-3526) REST APIs return object representation instead of string for config values, default values and recommended values

2016-04-07 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3526: -- Description: In the response of {code} PUT /connector-plugins/{name}/config/validate {code} The

[jira] [Updated] (KAFKA-3526) REST APIs return object representation instead of string for config values, default values and recommended values

2016-04-07 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3526: -- Description: In the response of PUT /connector-plugins/{name}/config/validate, The value.value,

[jira] [Created] (KAFKA-3526) REST APIs return object representation instead of string for config values, default values and recommended values

2016-04-07 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3526: - Summary: REST APIs return object representation instead of string for config values, default values and recommended values Key: KAFKA-3526 URL:

[jira] [Work started] (KAFKA-3520) System tests of config validate and list connectors REST APIs

2016-04-06 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3520 started by Liquan Pei. - > System tests of config validate and list connectors REST APIs >

[jira] [Created] (KAFKA-3520) System tests of config validate and list connectors REST APIs

2016-04-06 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3520: - Summary: System tests of config validate and list connectors REST APIs Key: KAFKA-3520 URL: https://issues.apache.org/jira/browse/KAFKA-3520 Project: Kafka Issue

[jira] [Commented] (KAFKA-3552) New Consumer: java.lang.OutOfMemoryError: Direct buffer memory

2016-04-12 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15238372#comment-15238372 ] Liquan Pei commented on KAFKA-3552: --- Hi Kanak, Can you share with us the consumer configuration file?

[jira] [Assigned] (KAFKA-3552) New Consumer: java.lang.OutOfMemoryError: Direct buffer memory

2016-04-12 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3552: - Assignee: Liquan Pei (was: Neha Narkhede) > New Consumer: java.lang.OutOfMemoryError: Direct

[jira] [Assigned] (KAFKA-3530) Making the broker-list option consistent across all tools

2016-04-08 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3530: - Assignee: Liquan Pei > Making the broker-list option consistent across all tools >

[jira] [Updated] (KAFKA-3316) Add Connect REST API to list available connector classes

2016-03-19 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3316: -- Affects Version/s: 0.10.0.0 Status: Patch Available (was: In Progress) > Add Connect

[jira] [Work started] (KAFKA-3316) Add Connect REST API to list available connector classes

2016-03-19 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3316 started by Liquan Pei. - > Add Connect REST API to list available connector classes >

[jira] [Updated] (KAFKA-3462) Allow SinkTasks to disable consumer offset commit

2016-03-24 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3462: -- Description: SinkTasks should be able to disable consumer offset commit if they manage offsets in the

[jira] [Work started] (KAFKA-3462) Allow SinkTasks to disable consumer offset commit

2016-03-24 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3462 started by Liquan Pei. - > Allow SinkTasks to disable consumer offset commit >

[jira] [Created] (KAFKA-3462) Allow SinkTasks to disable consumer offset commit

2016-03-24 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3462: - Summary: Allow SinkTasks to disable consumer offset commit Key: KAFKA-3462 URL: https://issues.apache.org/jira/browse/KAFKA-3462 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-3462) Allow SinkTasks to disable consumer offset commit

2016-03-24 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3462: -- Status: Patch Available (was: In Progress) > Allow SinkTasks to disable consumer offset commit >

[jira] [Updated] (KAFKA-3500) KafkaOffsetBackingStore set method needs to handle null

2016-04-04 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3500: -- Environment: (was: In some cases, the key or value for the offset map can be null. However, it

[jira] [Created] (KAFKA-3500) KafkaOffsetBackingStore set method needs to handle null

2016-04-04 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3500: - Summary: KafkaOffsetBackingStore set method needs to handle null Key: KAFKA-3500 URL: https://issues.apache.org/jira/browse/KAFKA-3500 Project: Kafka Issue Type:

[jira] [Work started] (KAFKA-3611) Remove WARNs when using reflections

2016-04-22 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3611 started by Liquan Pei. - > Remove WARNs when using reflections > > >

[jira] [Work stopped] (KAFKA-3611) Remove WARNs when using reflections

2016-04-22 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3611 stopped by Liquan Pei. - > Remove WARNs when using reflections > > >

[jira] [Updated] (KAFKA-3611) Remove WARNs when using reflections

2016-04-22 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3611: -- Status: Patch Available (was: In Progress) > Remove WARNs when using reflections >

[jira] [Work started] (KAFKA-3611) Remove WARNs when using reflections

2016-04-22 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3611 started by Liquan Pei. - > Remove WARNs when using reflections > > >

[jira] [Created] (KAFKA-3611) Remove WARNs when using reflections

2016-04-22 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3611: - Summary: Remove WARNs when using reflections Key: KAFKA-3611 URL: https://issues.apache.org/jira/browse/KAFKA-3611 Project: Kafka Issue Type: Improvement

[jira] [Assigned] (KAFKA-3457) KafkaConsumer.committed(...) hangs forever if port number is wrong

2016-04-21 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3457: - Assignee: Liquan Pei > KafkaConsumer.committed(...) hangs forever if port number is wrong >

[jira] [Assigned] (KAFKA-3527) Consumer commitAsync should not expose internal exceptions

2016-04-21 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3527: - Assignee: Liquan Pei (was: Jason Gustafson) > Consumer commitAsync should not expose internal

[jira] [Resolved] (KAFKA-2479) Add CopycatExceptions to indicate transient and permanent errors in a connector/task

2016-04-21 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei resolved KAFKA-2479. --- Resolution: Fixed > Add CopycatExceptions to indicate transient and permanent errors in a >

[jira] [Reopened] (KAFKA-3605) Connector REST endpoint allows incorrectly overriding the connector name

2016-04-21 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reopened KAFKA-3605: --- > Connector REST endpoint allows incorrectly overriding the connector name >

[jira] [Resolved] (KAFKA-3605) Connector REST endpoint allows incorrectly overriding the connector name

2016-04-21 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei resolved KAFKA-3605. --- Resolution: Fixed > Connector REST endpoint allows incorrectly overriding the connector name >

[jira] [Assigned] (KAFKA-3556) Improve group coordinator metrics

2016-04-21 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3556: - Assignee: Liquan Pei > Improve group coordinator metrics > - > >

[jira] [Assigned] (KAFKA-3459) Returning zero task configurations from a connector does not properly clean up existing tasks

2016-04-20 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3459: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Returning zero task configurations from a

[jira] [Assigned] (KAFKA-3035) Transient: kafka.api.PlaintextConsumerTest > testAutoOffsetReset FAILED

2016-04-20 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3035: - Assignee: Liquan Pei > Transient: kafka.api.PlaintextConsumerTest > testAutoOffsetReset FAILED >

[jira] [Assigned] (KAFKA-3213) [CONNECT] It looks like we are not backing off properly when reconfiguring tasks

2016-04-29 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3213: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > [CONNECT] It looks like we are not backing

[jira] [Commented] (KAFKA-3615) Exclude test jars in CLASSPATH of kafka-run-class.sh

2016-04-24 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15255889#comment-15255889 ] Liquan Pei commented on KAFKA-3615: --- [~enothereska] Kafka Connect provides a REST API to list installed

[jira] [Assigned] (KAFKA-3626) Transient failure in testGetAllTopicMetadata

2016-04-26 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3626: - Assignee: Liquan Pei > Transient failure in testGetAllTopicMetadata >

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

2016-04-21 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3606: - Summary: Traverse CLASSPATH during herder start to list connectors Key: KAFKA-3606 URL: https://issues.apache.org/jira/browse/KAFKA-3606 Project: Kafka Issue

[jira] [Created] (KAFKA-3615) Exclude test jars in CLASSPATH of kafka-run-class.sh

2016-04-23 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3615: - Summary: Exclude test jars in CLASSPATH of kafka-run-class.sh Key: KAFKA-3615 URL: https://issues.apache.org/jira/browse/KAFKA-3615 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-3734) Exceptions in SourceTask.commit() methods should cause task to stop and report failed state

2016-05-19 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3734: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Exceptions in SourceTask.commit() methods

[jira] [Assigned] (KAFKA-3739) Add no-arg constructor for library provided serdes

2016-05-20 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3739: - Assignee: Liquan Pei > Add no-arg constructor for library provided serdes >

[jira] [Updated] (KAFKA-3742) Can't run connect-distributed.sh with -daemon flag

2016-05-20 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3742: -- Summary: Can't run connect-distributed.sh with -daemon flag (was: Can't run connect-distributed with

[jira] [Assigned] (KAFKA-3742) Can't run connect-distributed with -daemon flag

2016-05-20 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3742: - Assignee: Liquan Pei > Can't run connect-distributed with -daemon flag >

[jira] [Updated] (KAFKA-3742) Can't run connect-distributed.sh with -daemon flag

2016-05-20 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3742: -- Description: Running on ubuntu 14.04. Discovered while experimenting various different kafka

[jira] [Updated] (KAFKA-3690) Avoid passing null to UnModifiableMap

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3690: -- Summary: Avoid passing null to UnModifiableMap (was: Avoid passing null pointers to UnModifiableMap)

[jira] [Created] (KAFKA-3690) Avoid passing null pointers to UnModifiableMap

2016-05-10 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3690: - Summary: Avoid passing null pointers to UnModifiableMap Key: KAFKA-3690 URL: https://issues.apache.org/jira/browse/KAFKA-3690 Project: Kafka Issue Type: Bug

[jira] [Work started] (KAFKA-3690) Avoid passing null to UnModifiableMap

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3690 started by Liquan Pei. - > Avoid passing null to UnModifiableMap > - > >

[jira] [Updated] (KAFKA-3692) Spaces in External CLASSPATH may cause it not be included in the CLASSPATH

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3692: -- Description: Currently, we doesn't use double quote when using CLASSPATH in kafka-run-class.sh. This

[jira] [Updated] (KAFKA-3692) Spaces in External CLASSPATH may cause it not be included in the CLASSPATH

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3692: -- Fix Version/s: (was: 0.10.0.0) 0.10.0.1 > Spaces in External CLASSPATH may cause

[jira] [Updated] (KAFKA-3692) Spaces in External CLASSPATH may cause it not be included in the CLASSPATH

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3692: -- Status: Patch Available (was: In Progress) > Spaces in External CLASSPATH may cause it not be included

[jira] [Created] (KAFKA-3692) Spaces in External CLASSPATH may cause it not be included in the CLASSPATH

2016-05-10 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3692: - Summary: Spaces in External CLASSPATH may cause it not be included in the CLASSPATH Key: KAFKA-3692 URL: https://issues.apache.org/jira/browse/KAFKA-3692 Project: Kafka

[jira] [Commented] (KAFKA-3690) Avoid passing null to UnmodifiableMap

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15279281#comment-15279281 ] Liquan Pei commented on KAFKA-3690: --- Agreed with [~ewencp]. I think we can add documentation to clarify

[jira] [Updated] (KAFKA-3690) Avoid passing null to UnmodifiableMap

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3690: -- Priority: Major (was: Blocker) > Avoid passing null to UnmodifiableMap >

[jira] [Updated] (KAFKA-3692) Spaces in External CLASSPATH may cause it not be included in the CLASSPATH

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3692: -- Priority: Major (was: Blocker) > Spaces in External CLASSPATH may cause it not be included in the

[jira] [Commented] (KAFKA-3690) Avoid passing null to UnmodifiableMap

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15279352#comment-15279352 ] Liquan Pei commented on KAFKA-3690: --- If JsonConverter is used for {code}internal.key.converter{code} or

[jira] [Updated] (KAFKA-3692) Wildcards in External CLASSPATH may cause it not be included in the CLASSPATH

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3692: -- Description: Currently, we doesn't use double quote when using CLASSPATH in kafka-run-class.sh. This

[jira] [Updated] (KAFKA-3690) Avoid passing null to UnmodifiableMap

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3690: -- Summary: Avoid passing null to UnmodifiableMap (was: Avoid passing null to UnModifiableMap) > Avoid

[jira] [Work started] (KAFKA-3692) Spaces in External CLASSPATH may cause it not be included in the CLASSPATH

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3692 started by Liquan Pei. - > Spaces in External CLASSPATH may cause it not be included in the CLASSPATH >

[jira] [Updated] (KAFKA-3692) Spaces in External CLASSPATH may cause it not be included in the CLASSPATH

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3692: -- Description: Currently, we doesn't use double quote when using CLASSPATH in (was: This may cause

[jira] [Updated] (KAFKA-3692) Wildcards in External CLASSPATH may cause it not be included in the CLASSPATH

2016-05-10 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3692: -- Summary: Wildcards in External CLASSPATH may cause it not be included in the CLASSPATH (was: Spaces in

[jira] [Assigned] (KAFKA-3705) Support non-key joining in KTable

2016-05-12 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3705: - Assignee: Liquan Pei (was: Guozhang Wang) > Support non-key joining in KTable >

[jira] [Updated] (KAFKA-3692) Wildcards in External CLASSPATH may cause it not be included in the CLASSPATH

2016-05-11 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3692: -- Fix Version/s: (was: 0.10.0.1) 0.10.0.0 > Wildcards in External CLASSPATH may

[jira] [Updated] (KAFKA-3692) Wildcards in External CLASSPATH may cause it not be included in the CLASSPATH

2016-05-11 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3692: -- Priority: Blocker (was: Major) > Wildcards in External CLASSPATH may cause it not be included in the

[jira] [Closed] (KAFKA-3582) remove references to Copcyat from connect property files

2016-04-29 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei closed KAFKA-3582. - > remove references to Copcyat from connect property files >

[jira] [Closed] (KAFKA-3615) Exclude test jars in CLASSPATH of kafka-run-class.sh

2016-04-29 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei closed KAFKA-3615. - > Exclude test jars in CLASSPATH of kafka-run-class.sh >

[jira] [Closed] (KAFKA-3611) Remove WARNs when using reflections

2016-04-29 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei closed KAFKA-3611. - > Remove WARNs when using reflections > > > Key:

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

2016-04-29 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei closed KAFKA-3606. - > Traverse CLASSPATH during herder start to list connectors >

[jira] [Closed] (KAFKA-3578) Allow cross origin HTTP requests on all HTTP methods

2016-04-29 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei closed KAFKA-3578. - > Allow cross origin HTTP requests on all HTTP methods >

[jira] [Updated] (KAFKA-3654) Config validation should validate both common and connector specific configurations

2016-05-03 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3654: -- Summary: Config validation should validate both common and connector specific configurations (was:

[jira] [Created] (KAFKA-3654) ConnectorConfig defs short circuit implementation config checks

2016-05-03 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3654: - Summary: ConnectorConfig defs short circuit implementation config checks Key: KAFKA-3654 URL: https://issues.apache.org/jira/browse/KAFKA-3654 Project: Kafka

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

2016-05-05 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15273305#comment-15273305 ] Liquan Pei commented on KAFKA-3587: --- Hi [~ecomar] I have a WIP PR, mind to take a look?

[jira] [Updated] (KAFKA-3671) Topics should not be in common ConnectorConfig definitions

2016-05-06 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3671: -- Summary: Topics should not be in common ConnectorConfig definitions (was: topics should not be in

[jira] [Work started] (KAFKA-3671) Topics should not be in common ConnectorConfig definitions

2016-05-06 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3671 started by Liquan Pei. - > Topics should not be in common ConnectorConfig definitions >

[jira] [Created] (KAFKA-3671) topics should not be in common ConnectorConfig definitions

2016-05-06 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3671: - Summary: topics should not be in common ConnectorConfig definitions Key: KAFKA-3671 URL: https://issues.apache.org/jira/browse/KAFKA-3671 Project: Kafka Issue

[jira] [Assigned] (KAFKA-3656) Avoid stressing system more when already under stress

2016-05-04 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3656: - Assignee: Liquan Pei > Avoid stressing system more when already under stress >

[jira] [Assigned] (KAFKA-3649) Add capability to query broker process for configuration properties

2016-05-04 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3649: - Assignee: Liquan Pei > Add capability to query broker process for configuration properties >

[jira] [Updated] (KAFKA-3656) Avoid stressing system more when already under stress

2016-05-04 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3656: -- Status: Patch Available (was: In Progress) > Avoid stressing system more when already under stress >

[jira] [Work started] (KAFKA-3656) Avoid stressing system more when already under stress

2016-05-04 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3656 started by Liquan Pei. - > Avoid stressing system more when already under stress >

[jira] [Assigned] (KAFKA-3487) Support per-connector/per-task classloaders in Connect

2016-05-05 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3487: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Support per-connector/per-task classloaders

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

2016-05-05 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15273584#comment-15273584 ] Liquan Pei commented on KAFKA-3587: --- [~ecomar] [~alekar] Moving the pessimistic check to the second

[jira] [Updated] (KAFKA-3654) ConnectorConfig short circuit implementation config validation

2016-05-03 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3654: -- Description: Right now if you call the validate endpoint with a config that has an invalid value for

[jira] [Updated] (KAFKA-3654) ConnectorConfig short circuit implementation config validation

2016-05-03 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3654: -- Summary: ConnectorConfig short circuit implementation config validation (was: ConnectorConfig defs

[jira] [Created] (KAFKA-3673) Connect tests dont handle concurrent config changes

2016-05-06 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3673: - Summary: Connect tests dont handle concurrent config changes Key: KAFKA-3673 URL: https://issues.apache.org/jira/browse/KAFKA-3673 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-3673) Connect tests dont handle concurrent config changes

2016-05-06 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3673: -- Description: [INFO - 2016-04-28 18:42:45,346 - runner - log - lineno:221]: SerialTestRunner:

[jira] [Work started] (KAFKA-3421) Update docs with new connector features

2016-04-15 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3421 started by Liquan Pei. - > Update docs with new connector features > --- >

[jira] [Assigned] (KAFKA-3578) Allow cross origin HTTP requests on all HTTP methods

2016-04-18 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3578: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Allow cross origin HTTP requests on all

[jira] [Created] (KAFKA-3578) Allow cross origin HTTP requests on all HTTP methods

2016-04-18 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3578: - Summary: Allow cross origin HTTP requests on all HTTP methods Key: KAFKA-3578 URL: https://issues.apache.org/jira/browse/KAFKA-3578 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-3582) remove references to Copcyat from connect property files

2016-04-18 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3582: - Assignee: Liquan Pei > remove references to Copcyat from connect property files >

  1   2   >