[jira] [Updated] (KAFKA-868) System Test - add test case for rolling controlled shutdown

[ https://issues.apache.org/jira/browse/KAFKA-868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-868: Resolution: Fixed Reviewer: Ewen Cheslack-Postava Fix Version/s:

[jira] [Resolved] (KAFKA-392) Refactor and optimize system tests

[ https://issues.apache.org/jira/browse/KAFKA-392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-392. - Resolution: Won't Fix Fix Version/s: (was: 0.10.0.0) This is for the

[jira] [Updated] (KAFKA-645) Create a shell script to run System Test with DEBUG details and "tee" console output to a file

[ https://issues.apache.org/jira/browse/KAFKA-645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-645: Resolution: Won't Fix Reviewer: Ewen Cheslack-Postava Status: Resolved

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15064523#comment-15064523 ] Ewen Cheslack-Postava commented on KAFKA-3006: -- [~gwenshap] I double checked because of

[jira] [Updated] (KAFKA-3008) Connect should parallelize task start/stop

[ https://issues.apache.org/jira/browse/KAFKA-3008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3008: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Connect should parallelize

[jira] [Created] (KAFKA-3008) Connect should parallelize task start/stop

Ewen Cheslack-Postava created KAFKA-3008: Summary: Connect should parallelize task start/stop Key: KAFKA-3008 URL: https://issues.apache.org/jira/browse/KAFKA-3008 Project: Kafka

[jira] [Resolved] (KAFKA-2990) NoSuchMethodError when Kafka is compiled with 1.8 and run on 1.7

[ https://issues.apache.org/jira/browse/KAFKA-2990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2990. -- Resolution: Fixed Fix Version/s: 0.9.1.0 0.9.0.1

[jira] [Resolved] (KAFKA-1589) Strengthen System Tests

[ https://issues.apache.org/jira/browse/KAFKA-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-1589. -- Resolution: Won't Fix Assignee: Ewen Cheslack-Postava (was: Gwen Shapira)

[jira] [Resolved] (KAFKA-1613) Improve system test documentation

[ https://issues.apache.org/jira/browse/KAFKA-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-1613. -- Resolution: Won't Fix Assignee: Ewen Cheslack-Postava (was: Gwen Shapira)

[jira] [Updated] (KAFKA-2070) Replace OffsetRequest/response with ListOffsetRequest/response from org.apache.kafka.common.requests

[ https://issues.apache.org/jira/browse/KAFKA-2070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2070: - Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was:

[jira] [Commented] (KAFKA-2967) Move Kafka documentation to ReStructuredText

[ https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15050416#comment-15050416 ] Ewen Cheslack-Postava commented on KAFKA-2967: -- {quote} The big problem with the existing

[jira] [Resolved] (KAFKA-2926) [MirrorMaker] InternalRebalancer calls wrong method of external rebalancer

[ https://issues.apache.org/jira/browse/KAFKA-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2926. -- Resolution: Fixed Fix Version/s: 0.9.1.0 0.9.0.1

[jira] [Commented] (KAFKA-2926) [MirrorMaker] InternalRebalancer calls wrong method of external rebalancer

[ https://issues.apache.org/jira/browse/KAFKA-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15051658#comment-15051658 ] Ewen Cheslack-Postava commented on KAFKA-2926: -- [~gwenshap] 1 line down, 69,999 to go. >

[jira] [Updated] (KAFKA-2896) System test for partition re-assignment

[ https://issues.apache.org/jira/browse/KAFKA-2896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2896: - Reviewer: Ewen Cheslack-Postava > System test for partition re-assignment >

[jira] [Updated] (KAFKA-2896) System test for partition re-assignment

[ https://issues.apache.org/jira/browse/KAFKA-2896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2896: - Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was:

[jira] [Updated] (KAFKA-2928) system tests: failures in version-related sanity checks

[ https://issues.apache.org/jira/browse/KAFKA-2928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2928: - Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was:

[jira] [Updated] (KAFKA-2578) Client Metadata internal state should be synchronized

[ https://issues.apache.org/jira/browse/KAFKA-2578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2578: - Resolution: Fixed Fix Version/s: 0.9.1.0 0.9.0.1

[jira] [Updated] (KAFKA-2927) System tests: reduce storage footprint of collected logs

[ https://issues.apache.org/jira/browse/KAFKA-2927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2927: - Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was:

[jira] [Updated] (KAFKA-2070) Replace OffsetRequest/response with ListOffsetRequest/response from org.apache.kafka.common.requests

[ https://issues.apache.org/jira/browse/KAFKA-2070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2070: - Reviewer: Ewen Cheslack-Postava > Replace OffsetRequest/response with

[jira] [Updated] (KAFKA-2578) Client Metadata internal state should be synchronized

[ https://issues.apache.org/jira/browse/KAFKA-2578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2578: - Reviewer: Ewen Cheslack-Postava > Client Metadata internal state should be

[jira] [Resolved] (KAFKA-2667) Copycat KafkaBasedLogTest.testSendAndReadToEnd transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2667. -- Resolution: Fixed Reviewer: Ewen Cheslack-Postava (was: Guozhang Wang)

[jira] [Resolved] (KAFKA-2839) Kafka connect log test failing

[ https://issues.apache.org/jira/browse/KAFKA-2839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2839. -- Resolution: Duplicate Reviewer: Ewen Cheslack-Postava (was: Gwen

[jira] [Commented] (KAFKA-2667) Copycat KafkaBasedLogTest.testSendAndReadToEnd transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047586#comment-15047586 ] Ewen Cheslack-Postava commented on KAFKA-2667: -- Yes, that seems like a very likely culprit.

[jira] [Created] (KAFKA-2932) Adjust importance level of Kafka Connect configs

Ewen Cheslack-Postava created KAFKA-2932: Summary: Adjust importance level of Kafka Connect configs Key: KAFKA-2932 URL: https://issues.apache.org/jira/browse/KAFKA-2932 Project: Kafka

[jira] [Created] (KAFKA-2934) Offset storage file configuration in Connect standalone mode is not included in StandaloneConfig

Ewen Cheslack-Postava created KAFKA-2934: Summary: Offset storage file configuration in Connect standalone mode is not included in StandaloneConfig Key: KAFKA-2934 URL:

[jira] [Created] (KAFKA-2941) Docs for key/value converter in Kafka connect are unclear

Ewen Cheslack-Postava created KAFKA-2941: Summary: Docs for key/value converter in Kafka connect are unclear Key: KAFKA-2941 URL: https://issues.apache.org/jira/browse/KAFKA-2941 Project:

[jira] [Commented] (KAFKA-2934) Offset storage file configuration in Connect standalone mode is not included in StandaloneConfig

[ https://issues.apache.org/jira/browse/KAFKA-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15036882#comment-15036882 ] Ewen Cheslack-Postava commented on KAFKA-2934: -- Also found a couple of other configs that

[jira] [Commented] (KAFKA-2914) Kafka Connect Source connector for HBase

[ https://issues.apache.org/jira/browse/KAFKA-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15035439#comment-15035439 ] Ewen Cheslack-Postava commented on KAFKA-2914: -- [~nielsbasjes] Agreed that an HBase source

[jira] [Created] (KAFKA-2935) Remove vestigial CLUSTER_CONFIG in WorkerConfig

Ewen Cheslack-Postava created KAFKA-2935: Summary: Remove vestigial CLUSTER_CONFIG in WorkerConfig Key: KAFKA-2935 URL: https://issues.apache.org/jira/browse/KAFKA-2935 Project: Kafka

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

Ewen Cheslack-Postava created KAFKA-2925: Summary: NullPointerException if FileStreamSinkTask is stopped before initialization finishes Key: KAFKA-2925 URL:

[jira] [Created] (KAFKA-2906) Kafka Connect javadocs not built properly

Ewen Cheslack-Postava created KAFKA-2906: Summary: Kafka Connect javadocs not built properly Key: KAFKA-2906 URL: https://issues.apache.org/jira/browse/KAFKA-2906 Project: Kafka

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

Ewen Cheslack-Postava created KAFKA-2894: Summary: WorkerSinkTask doesn't handle rewinding offsets on rebalance Key: KAFKA-2894 URL: https://issues.apache.org/jira/browse/KAFKA-2894 Project:

[jira] [Created] (KAFKA-2886) WorkerSinkTask doesn't catch exceptions from rebalance callbacks

Ewen Cheslack-Postava created KAFKA-2886: Summary: WorkerSinkTask doesn't catch exceptions from rebalance callbacks Key: KAFKA-2886 URL: https://issues.apache.org/jira/browse/KAFKA-2886

[jira] [Commented] (KAFKA-2880) Fetcher.getTopicMetadata NullPointerException when broker cannot be reached

[ https://issues.apache.org/jira/browse/KAFKA-2880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15023766#comment-15023766 ] Ewen Cheslack-Postava commented on KAFKA-2880: -- [~hachikuji] Agreed, makes sense to round out

[jira] [Created] (KAFKA-2880) Fetcher.getTopicMetadata NullPointerException when broker cannot be reached

Ewen Cheslack-Postava created KAFKA-2880: Summary: Fetcher.getTopicMetadata NullPointerException when broker cannot be reached Key: KAFKA-2880 URL: https://issues.apache.org/jira/browse/KAFKA-2880

[jira] [Commented] (KAFKA-2861) system tests: grep logs for errors as part of validation

[ https://issues.apache.org/jira/browse/KAFKA-2861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15013227#comment-15013227 ] Ewen Cheslack-Postava commented on KAFKA-2861: -- [~geoffra] Of course, the problem with this

[jira] [Commented] (KAFKA-2861) system tests: grep logs for errors as part of validation

[ https://issues.apache.org/jira/browse/KAFKA-2861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15015036#comment-15015036 ] Ewen Cheslack-Postava commented on KAFKA-2861: -- [~geoffra] Right. The whitelist could work,

[jira] [Updated] (KAFKA-2867) Missing synchronization and improperly handled InterruptException in WorkerSourceTask

[ https://issues.apache.org/jira/browse/KAFKA-2867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2867: - Status: Patch Available (was: Open) > Missing synchronization and improperly

[jira] [Created] (KAFKA-2867) Missing synchronization and improperly handled InterruptException in WorkerSourceTask

Ewen Cheslack-Postava created KAFKA-2867: Summary: Missing synchronization and improperly handled InterruptException in WorkerSourceTask Key: KAFKA-2867 URL:

[jira] [Created] (KAFKA-2859) Deadlock in WorkerSourceTask

Ewen Cheslack-Postava created KAFKA-2859: Summary: Deadlock in WorkerSourceTask Key: KAFKA-2859 URL: https://issues.apache.org/jira/browse/KAFKA-2859 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-1904) run sanity failed test

[ https://issues.apache.org/jira/browse/KAFKA-1904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-1904. -- Resolution: Won't Fix Assignee: Ewen Cheslack-Postava This was from the

[jira] [Updated] (KAFKA-2859) Deadlock in WorkerSourceTask

[ https://issues.apache.org/jira/browse/KAFKA-2859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2859: - Status: Patch Available (was: Open) > Deadlock in WorkerSourceTask >

[jira] [Created] (KAFKA-2848) Use withClientSslSupport/withClientSaslSupport in Kafka Connect

Ewen Cheslack-Postava created KAFKA-2848: Summary: Use withClientSslSupport/withClientSaslSupport in Kafka Connect Key: KAFKA-2848 URL: https://issues.apache.org/jira/browse/KAFKA-2848

[jira] [Updated] (KAFKA-2826) Make Kafka Connect ducktape services easier to extend

[ https://issues.apache.org/jira/browse/KAFKA-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2826: - Summary: Make Kafka Connect ducktape services easier to extend (was: Make Kafka

[jira] [Created] (KAFKA-2826) Make Kafka Connect ducktaep services easier to extend

Ewen Cheslack-Postava created KAFKA-2826: Summary: Make Kafka Connect ducktaep services easier to extend Key: KAFKA-2826 URL: https://issues.apache.org/jira/browse/KAFKA-2826 Project: Kafka

[jira] [Created] (KAFKA-2828) Circular import in system tests

Ewen Cheslack-Postava created KAFKA-2828: Summary: Circular import in system tests Key: KAFKA-2828 URL: https://issues.apache.org/jira/browse/KAFKA-2828 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-2807) Movement of throughput throttler to common broke upgrade tests

[ https://issues.apache.org/jira/browse/KAFKA-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15002636#comment-15002636 ] Ewen Cheslack-Postava edited comment on KAFKA-2807 at 11/12/15 7:01 PM:

[jira] [Reopened] (KAFKA-2807) Movement of throughput throttler to common broke upgrade tests

[ https://issues.apache.org/jira/browse/KAFKA-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reopened KAFKA-2807: -- Turns out the original patch actually broke things. The way the projects are named

[jira] [Created] (KAFKA-2814) Kafka Connect system tests using REST interface fail on AWS

Ewen Cheslack-Postava created KAFKA-2814: Summary: Kafka Connect system tests using REST interface fail on AWS Key: KAFKA-2814 URL: https://issues.apache.org/jira/browse/KAFKA-2814 Project:

[jira] [Commented] (KAFKA-2807) Movement of throughput throttler to common broke upgrade tests

[ https://issues.apache.org/jira/browse/KAFKA-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000934#comment-15000934 ] Ewen Cheslack-Postava commented on KAFKA-2807: -- [~geoffra] Hmm, I moved it into common

[jira] [Updated] (KAFKA-2807) Movement of throughput throttler to common broke upgrade tests

[ https://issues.apache.org/jira/browse/KAFKA-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2807: - Assignee: Ewen Cheslack-Postava (was: Geoff Anderson) Reviewer:

[jira] [Updated] (KAFKA-2797) Release artifact expects a git repository for the release audit tool (RAT)

[ https://issues.apache.org/jira/browse/KAFKA-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2797: - Reviewer: Gwen Shapira Status: Patch Available (was: Open) > Release

[jira] [Assigned] (KAFKA-2797) Release artifact expects a git repository for the release audit tool (RAT)

[ https://issues.apache.org/jira/browse/KAFKA-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-2797: Assignee: Ewen Cheslack-Postava > Release artifact expects a git

[jira] [Created] (KAFKA-2798) Kafka Connect distributed configs can conflict with producer/consumer configs, making it impossible to control them independently

Ewen Cheslack-Postava created KAFKA-2798: Summary: Kafka Connect distributed configs can conflict with producer/consumer configs, making it impossible to control them independently Key: KAFKA-2798 URL:

[jira] [Created] (KAFKA-2803) Add hard bounce system test for distributed Kafka Connect

Ewen Cheslack-Postava created KAFKA-2803: Summary: Add hard bounce system test for distributed Kafka Connect Key: KAFKA-2803 URL: https://issues.apache.org/jira/browse/KAFKA-2803 Project:

[jira] [Updated] (KAFKA-2803) Add hard bounce system test for distributed Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2803: - Status: Patch Available (was: Open) > Add hard bounce system test for

[jira] [Created] (KAFKA-2793) ConsoleConsumer crashes with new consumer when using keys because of incorrect deserializer

Ewen Cheslack-Postava created KAFKA-2793: Summary: ConsoleConsumer crashes with new consumer when using keys because of incorrect deserializer Key: KAFKA-2793 URL:

[jira] [Created] (KAFKA-2792) KafkaConsumer.close() can block unnecessarily due to leave group waiting for a reply

Ewen Cheslack-Postava created KAFKA-2792: Summary: KafkaConsumer.close() can block unnecessarily due to leave group waiting for a reply Key: KAFKA-2792 URL:

[jira] [Created] (KAFKA-2782) Incorrect assertion in KafkaBasedLogTest.testSendAndReadToEnd

Ewen Cheslack-Postava created KAFKA-2782: Summary: Incorrect assertion in KafkaBasedLogTest.testSendAndReadToEnd Key: KAFKA-2782 URL: https://issues.apache.org/jira/browse/KAFKA-2782 Project:

[jira] [Updated] (KAFKA-2782) Incorrect assertion in KafkaBasedLogTest.testSendAndReadToEnd

[ https://issues.apache.org/jira/browse/KAFKA-2782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2782: - Status: Patch Available (was: Open) > Incorrect assertion in

[jira] [Updated] (KAFKA-2781) Signing jars shouldn't be required for install task

[ https://issues.apache.org/jira/browse/KAFKA-2781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2781: - Status: Patch Available (was: Open) > Signing jars shouldn't be required for

[jira] [Created] (KAFKA-2781) Signing jars shouldn't be required for install task

Ewen Cheslack-Postava created KAFKA-2781: Summary: Signing jars shouldn't be required for install task Key: KAFKA-2781 URL: https://issues.apache.org/jira/browse/KAFKA-2781 Project: Kafka

[jira] [Created] (KAFKA-2785) Copycat jars not included in release tar gz

Ewen Cheslack-Postava created KAFKA-2785: Summary: Copycat jars not included in release tar gz Key: KAFKA-2785 URL: https://issues.apache.org/jira/browse/KAFKA-2785 Project: Kafka

[jira] [Updated] (KAFKA-2379) Add Copycat documentation

[ https://issues.apache.org/jira/browse/KAFKA-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2379: - Reviewer: Gwen Shapira Status: Patch Available (was: Open) > Add Copycat

[jira] [Updated] (KAFKA-2785) Copycat jars not included in release tar gz

[ https://issues.apache.org/jira/browse/KAFKA-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2785: - Status: Patch Available (was: Open) > Copycat jars not included in release tar

[jira] [Created] (KAFKA-2786) Only invoke SinkTask onPartitionsRevoked and commitOffsets after task has fully started

Ewen Cheslack-Postava created KAFKA-2786: Summary: Only invoke SinkTask onPartitionsRevoked and commitOffsets after task has fully started Key: KAFKA-2786 URL:

[jira] [Created] (KAFKA-2774) Rename Copycat -> Kafka Connect

Ewen Cheslack-Postava created KAFKA-2774: Summary: Rename Copycat -> Kafka Connect Key: KAFKA-2774 URL: https://issues.apache.org/jira/browse/KAFKA-2774 Project: Kafka Issue Type:

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

[ https://issues.apache.org/jira/browse/KAFKA-2375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14995961#comment-14995961 ] Ewen Cheslack-Postava commented on KAFKA-2375: -- [~speaktoraghav] I think you need to be added

[jira] [Created] (KAFKA-2775) Copycat exceptions should be in api package so they can be caught by user code without any dependencies other than api

Ewen Cheslack-Postava created KAFKA-2775: Summary: Copycat exceptions should be in api package so they can be caught by user code without any dependencies other than api Key: KAFKA-2775 URL:

[jira] [Updated] (KAFKA-2778) Use zero loss settings for producer in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-2778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2778: - Status: Patch Available (was: Open) > Use zero loss settings for producer in

[jira] [Created] (KAFKA-2776) JsonConverter uses wrong key to look up schema conversion cache size configuration

Ewen Cheslack-Postava created KAFKA-2776: Summary: JsonConverter uses wrong key to look up schema conversion cache size configuration Key: KAFKA-2776 URL: https://issues.apache.org/jira/browse/KAFKA-2776

[jira] [Updated] (KAFKA-2774) Rename Copycat -> Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-2774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2774: - Status: Patch Available (was: Open) > Rename Copycat -> Kafka Connect >

[jira] [Updated] (KAFKA-2776) JsonConverter uses wrong key to look up schema conversion cache size configuration

[ https://issues.apache.org/jira/browse/KAFKA-2776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2776: - Reviewer: Gwen Shapira Status: Patch Available (was: Open) > JsonConverter

[jira] [Created] (KAFKA-2778) Use zero loss settings for producer in Kafka Connect

Ewen Cheslack-Postava created KAFKA-2778: Summary: Use zero loss settings for producer in Kafka Connect Key: KAFKA-2778 URL: https://issues.apache.org/jira/browse/KAFKA-2778 Project: Kafka

[jira] [Updated] (KAFKA-2775) Copycat exceptions should be in api package so they can be caught by user code without any dependencies other than api

[ https://issues.apache.org/jira/browse/KAFKA-2775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2775: - Status: Patch Available (was: Open) > Copycat exceptions should be in api

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

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2480: - Reviewer: Gwen Shapira Status: Patch Available (was: Reopened) > Handle

[jira] [Updated] (KAFKA-2764) Copycat APIs should use Map<String, String> instead of Properties

[ https://issues.apache.org/jira/browse/KAFKA-2764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2764: - Status: Patch Available (was: Open) > Copycat APIs should use Map

[jira] [Created] (KAFKA-2764) Copycat APIs should use Map<String, String> instead of Properties

Ewen Cheslack-Postava created KAFKA-2764: Summary: Copycat APIs should use Map instead of Properties Key: KAFKA-2764 URL: https://issues.apache.org/jira/browse/KAFKA-2764

[jira] [Updated] (KAFKA-2713) Copycat worker should not call connector's/task's start methods in the control thread

[ https://issues.apache.org/jira/browse/KAFKA-2713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2713: - Status: Patch Available (was: Open) > Copycat worker should not call

[jira] [Created] (KAFKA-2765) Connectors and tasks should have versions that can be reported when they are instantiated

Ewen Cheslack-Postava created KAFKA-2765: Summary: Connectors and tasks should have versions that can be reported when they are instantiated Key: KAFKA-2765 URL:

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

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-2480: Assignee: Ewen Cheslack-Postava (was: Liquan Pei) > Handle

[jira] [Created] (KAFKA-2752) Add clean bounce system test for distributed Copycat

Ewen Cheslack-Postava created KAFKA-2752: Summary: Add clean bounce system test for distributed Copycat Key: KAFKA-2752 URL: https://issues.apache.org/jira/browse/KAFKA-2752 Project: Kafka

[jira] [Updated] (KAFKA-2759) Mirror maker can leave gaps of missing messages if the process dies after a partition is reset and before the first offset commit

[ https://issues.apache.org/jira/browse/KAFKA-2759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2759: - Description: Based on investigation of KAFKA-2747. When mirror maker first starts

[jira] [Created] (KAFKA-2759) Mirror maker can leave gaps of missing messages if the process dies after a partition is reset and before the first offset commit

Ewen Cheslack-Postava created KAFKA-2759: Summary: Mirror maker can leave gaps of missing messages if the process dies after a partition is reset and before the first offset commit Key: KAFKA-2759 URL:

[jira] [Commented] (KAFKA-2759) Mirror maker can leave gaps of missing messages if the process dies after a partition is reset and before the first offset commit

[ https://issues.apache.org/jira/browse/KAFKA-2759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993055#comment-14993055 ] Ewen Cheslack-Postava commented on KAFKA-2759: -- [~becket_qin] Yes, that would work, though we

[jira] [Created] (KAFKA-2748) SinkTasks do not handle rebalances and offset commit properly

Ewen Cheslack-Postava created KAFKA-2748: Summary: SinkTasks do not handle rebalances and offset commit properly Key: KAFKA-2748 URL: https://issues.apache.org/jira/browse/KAFKA-2748 Project:

[jira] [Created] (KAFKA-2741) Source/SinkTaskContext should be interfaces and implementations kept in runtime jar

Ewen Cheslack-Postava created KAFKA-2741: Summary: Source/SinkTaskContext should be interfaces and implementations kept in runtime jar Key: KAFKA-2741 URL: https://issues.apache.org/jira/browse/KAFKA-2741

[jira] [Created] (KAFKA-2742) SourceTaskOffsetCommitter does not properly remove commit tasks when they are already in progress

Ewen Cheslack-Postava created KAFKA-2742: Summary: SourceTaskOffsetCommitter does not properly remove commit tasks when they are already in progress Key: KAFKA-2742 URL:

[jira] [Created] (KAFKA-2743) Forwarding task reconfigurations in Copycat can deadlock with rebalances and has no backoff

Ewen Cheslack-Postava created KAFKA-2743: Summary: Forwarding task reconfigurations in Copycat can deadlock with rebalances and has no backoff Key: KAFKA-2743 URL:

[jira] [Created] (KAFKA-2744) WorkerSourceTask commits offsets too early when stopping

Ewen Cheslack-Postava created KAFKA-2744: Summary: WorkerSourceTask commits offsets too early when stopping Key: KAFKA-2744 URL: https://issues.apache.org/jira/browse/KAFKA-2744 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reopened KAFKA-2480: -- Oops, I think this got misfiled. The actual JIRA fixed by PR 340 is KAFKA-2481. >

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

[ https://issues.apache.org/jira/browse/KAFKA-2481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2481. -- Resolution: Fixed Reviewer: Gwen Shapira This has been resolved via

[jira] [Resolved] (KAFKA-1771) replicate_testsuite data verification broken if num_partitions > replica_factor

[ https://issues.apache.org/jira/browse/KAFKA-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-1771. -- Resolution: Invalid No longer valid since the old system tests have been

[jira] [Created] (KAFKA-2713) Copycat worker should not call connector's/task's start methods in the control thread

Ewen Cheslack-Postava created KAFKA-2713: Summary: Copycat worker should not call connector's/task's start methods in the control thread Key: KAFKA-2713 URL:

[jira] [Resolved] (KAFKA-1734) System test metric plotting nonexistent file warnings

[ https://issues.apache.org/jira/browse/KAFKA-1734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-1734. -- Resolution: Invalid No longer valid since the old system tests have been

[jira] [Commented] (KAFKA-2644) Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL

[ https://issues.apache.org/jira/browse/KAFKA-2644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14974964#comment-14974964 ] Ewen Cheslack-Postava commented on KAFKA-2644: -- [~rsivaram] Yes, that makes sense. I started

[jira] [Commented] (KAFKA-2644) Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL

[ https://issues.apache.org/jira/browse/KAFKA-2644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14974470#comment-14974470 ] Ewen Cheslack-Postava commented on KAFKA-2644: -- [~junrao] [~rsivaram] Auth for Confluent's

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

[ https://issues.apache.org/jira/browse/KAFKA-2369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2369 started by Ewen Cheslack-Postava. > Add Copycat REST API > > >

[jira] [Commented] (KAFKA-2644) Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL

[ https://issues.apache.org/jira/browse/KAFKA-2644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14974544#comment-14974544 ] Ewen Cheslack-Postava commented on KAFKA-2644: -- Yeah, that seems like a reasonable solution.

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

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

<    5   6   7   8   9   10   11   12   13   14   >