[jira] [Created] (KAFKA-7023) Kafka Streams RocksDB bulk loading config may not be honored with customized RocksDBConfigSetter

2018-06-07 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-7023: - Summary: Kafka Streams RocksDB bulk loading config may not be honored with customized RocksDBConfigSetter Key: KAFKA-7023 URL: https://issues.apache.org/jira/browse/KAFKA-7023

[jira] [Created] (KAFKA-7103) Use bulkloading for RocksDBSegmentedBytesStore during init

2018-06-26 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-7103: - Summary: Use bulkloading for RocksDBSegmentedBytesStore during init Key: KAFKA-7103 URL: https://issues.apache.org/jira/browse/KAFKA-7103 Project: Kafka Issue Type

[jira] [Created] (KAFKA-7105) Refactor RocksDBSegmentsBatchingRestoreCallback and RocksDBBatchingRestoreCallback into a single class

2018-06-26 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-7105: - Summary: Refactor RocksDBSegmentsBatchingRestoreCallback and RocksDBBatchingRestoreCallback into a single class Key: KAFKA-7105 URL: https://issues.apache.org/jira/browse/KAFKA-7105

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

[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] [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: -- Summary: Can't run connect-distributed.sh with -daemon flag (was: Can't run connect-distributed with -d

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

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

[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: https://issues.apache.org/jira/browse

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

[jira] [Assigned] (KAFKA-3829) Warn that kafka-connect group.id must not conflict with connector names

2016-06-20 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3829: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Warn that kafka-connect group.id must not co

[jira] [Assigned] (KAFKA-3868) New producer metric record-size-avg does not provide average record size as advertised

2016-06-20 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3868: - Assignee: Liquan Pei > New producer metric record-size-avg does not provide average record size a

[jira] [Created] (KAFKA-3920) Add Schema source connector to Kafka Connect

2016-06-29 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3920: - Summary: Add Schema source connector to Kafka Connect Key: KAFKA-3920 URL: https://issues.apache.org/jira/browse/KAFKA-3920 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-4002) task.open() should be invoked in case that 0 partitions is assigned to task.

2016-07-27 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-4002: - Summary: task.open() should be invoked in case that 0 partitions is assigned to task. Key: KAFKA-4002 URL: https://issues.apache.org/jira/browse/KAFKA-4002 Project: Kafka

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

[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] [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: -- Description: SinkTasks should be able to disable consumer offset commit if they manage offsets in the s

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

[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] [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] [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] [Updated] (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 ] Liquan Pei updated KAFKA-3520: -- Status: Patch Available (was: In Progress) > System tests of config validate and list connectors REST A

[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, 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: https://issues.apache.org/jira/browse/KA

[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 value.v

[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 value.v

[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: -- Status: Patch Available (was: In Progress) > REST APIs return object representation instead of string f

[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, > defaul

[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] [Commented] (KAFKA-3527) Consumer commitAsync should not expose internal exceptions

2016-04-09 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15233722#comment-15233722 ] Liquan Pei commented on KAFKA-3527: --- [~jasong35] Do you mind if I take this? > Consume

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

[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&focusedCommentId=15238372#comment-15238372 ] Liquan Pei commented on KAFKA-3552: --- Hi Kanak, Can you share with us the consumer confi

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

2016-04-14 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3421: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Update docs with new connector features > --

[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-3571) Traits for utilities like ConsumerGroupCommand

2016-04-16 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3571: - Assignee: Liquan Pei > Traits for utilities like ConsumerGroupCommand > -

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

2016-04-17 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3421: -- Status: Patch Available (was: In Progress) > Update docs with new connector features >

[jira] [Commented] (KAFKA-3573) JSON (de)serialization for kafka-client

2016-04-17 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15244768#comment-15244768 ] Liquan Pei commented on KAFKA-3573: --- Thanks for working on this. Currently, there is a J

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

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

[jira] [Created] (KAFKA-3583) Docs on pause/resume/restart APIs.

2016-04-18 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3583: - Summary: Docs on pause/resume/restart APIs. Key: KAFKA-3583 URL: https://issues.apache.org/jira/browse/KAFKA-3583 Project: Kafka Issue Type: Improvement

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

[jira] [Work started] (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 ] Work on KAFKA-3582 started by Liquan Pei. - > remove references to Copcyat from connect property files > --

[jira] [Updated] (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 updated KAFKA-3582: -- Status: Patch Available (was: In Progress) > remove references to Copcyat from connect property files >

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

[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] [Work started] (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 ] Work on KAFKA-3459 started by Liquan Pei. - > Returning zero task configurations from a connector does not properly clean > up exi

[jira] [Updated] (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 updated KAFKA-3459: -- Status: Patch Available (was: In Progress) > Returning zero task configurations from a connector does n

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

[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] [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] [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 ex

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

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

[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&focusedCommentId=15255889#comment-15255889 ] Liquan Pei commented on KAFKA-3615: --- [~enothereska] Kafka Connect provides a REST API to

[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] [Assigned] (KAFKA-3627) New consumer doesn't run delayed tasks while under load

2016-04-26 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3627: - Assignee: Liquan Pei (was: Neha Narkhede) > New consumer doesn't run delayed tasks while under l

[jira] [Assigned] (KAFKA-3637) Add method that checks if streams are initialised

2016-04-29 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3637: - Assignee: Liquan Pei > Add method that checks if streams are initialised > --

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

[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-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] [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: KAFKA-3

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

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

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

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

[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] [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&focusedCommentId=15273305#comment-15273305 ] Liquan Pei commented on KAFKA-3587: --- Hi [~ecomar] I have a WIP PR, mind to take a look?

[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&focusedCommentId=15273584#comment-15273584 ] Liquan Pei commented on KAFKA-3587: --- [~ecomar] [~alekar] Moving the pessimistic check to

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

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

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

[jira] [Created] (KAFKA-3684) Not all SinkConnectorConfig configs are returned

2016-05-09 Thread Liquan Pei (JIRA)
Liquan Pei created KAFKA-3684: - Summary: Not all SinkConnectorConfig configs are returned Key: KAFKA-3684 URL: https://issues.apache.org/jira/browse/KAFKA-3684 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-3684) Not all SinkConnectorConfig configs are returned

2016-05-09 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3684: -- Status: Patch Available (was: In Progress) > Not all SinkConnectorConfig configs are returned > --

[jira] [Work started] (KAFKA-3684) Not all SinkConnectorConfig configs are returned

2016-05-09 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3684 started by Liquan Pei. - > Not all SinkConnectorConfig configs are returned > -

[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] [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] [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 CLASS

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

  1   2   >