[jira] [Commented] (KAFKA-3144) report members with no assigned partitions in ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-3144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331301#comment-15331301 ] Ismael Juma commented on KAFKA-3144: [~vahid], also see https://github.com/apache/kafk

[jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331335#comment-15331335 ] Ismael Juma commented on KAFKA-2857: I'd be OK with just improving the message as Jaso

[jira] [Commented] (KAFKA-3837) Report the name of the blocking thread when throwing ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-3837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331377#comment-15331377 ] Simon Cooper commented on KAFKA-3837: - I would say the thread name is much more useful

[jira] [Comment Edited] (KAFKA-3837) Report the name of the blocking thread when throwing ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-3837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331377#comment-15331377 ] Simon Cooper edited comment on KAFKA-3837 at 6/15/16 8:23 AM: --

Re: [jira] [Commented] (KAFKA-3841) MirrorMaker topic renaming

We have also something similar, it's real easy to use a message handler, in our case we check for a bit to determine if we already copied the event, and change the topic name in dev-mode. You can configure a string to pass to your messageHandler for each instance. On Wed, Jun 15, 2016 at 1:38 AM N

[jira] [Created] (KAFKA-3843) Endless consuming messages in Kafka cluster

Tomas Benc created KAFKA-3843: - Summary: Endless consuming messages in Kafka cluster Key: KAFKA-3843 URL: https://issues.apache.org/jira/browse/KAFKA-3843 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-1429) Yet another deadlock in controller shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331523#comment-15331523 ] Pengwei commented on KAFKA-1429: I can still reproduce this issue in 0.9.0.0 or 0.9.0.1,

[jira] [Work started] (KAFKA-3839) Handling null keys in KTable.groupBy

[ https://issues.apache.org/jira/browse/KAFKA-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3839 started by Jeyhun Karimov. - > Handling null keys in KTable.groupBy > >

Complexe Event Processing on top of KafkaStreams

Hi Team Kafka, Currently, I'm working on an small library to implement "complex event processing" on top of Kafka Streams : https://github.com/fhussonnois/kafkastreams-cep The idea came from the flink-cep library and the project is based on the same research paper. I'm developping this project f

[jira] [Created] (KAFKA-3844) Sort configuration items in log

Xing Huang created KAFKA-3844: - Summary: Sort configuration items in log Key: KAFKA-3844 URL: https://issues.apache.org/jira/browse/KAFKA-3844 Project: Kafka Issue Type: Improvement Com

Re: [DISCUSS] KIP-4 Create Topic Schema

Thanks for the responses Grant. Fine about keeping replication_factor as INT32 (you mentioned 32k partitions in your reply, but I was talking about replication_factor which doesn't seem feasible to ever be that large. I didn't mention num_partitions for the reason you mentioned). Ewen's reply sum

[jira] [Commented] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331709#comment-15331709 ] Debowczyk commented on KAFKA-3410: -- Hi, are there plans to solve this issue? We had simil

[jira] [Comment Edited] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331709#comment-15331709 ] Debowczyk edited comment on KAFKA-3410 at 6/15/16 1:11 PM: --- Hi,

[GitHub] kafka pull request #1508: MINOR: Fix quota violation exception message

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/1508 MINOR: Fix quota violation exception message You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka MINOR-quota-exception Al

[GitHub] kafka pull request #1509: KAFKA-3691: Confusing logging during metadata upda...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/1509 KAFKA-3691: Confusing logging during metadata update timeout You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/kafka timeout-logging

[jira] [Commented] (KAFKA-3691) Confusing logging during metadata update timeout

[ https://issues.apache.org/jira/browse/KAFKA-3691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331906#comment-15331906 ] ASF GitHub Bot commented on KAFKA-3691: --- GitHub user granthenke opened a pull reques

[jira] [Updated] (KAFKA-3691) Confusing logging during metadata update timeout

[ https://issues.apache.org/jira/browse/KAFKA-3691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3691: --- Status: Patch Available (was: Open) > Confusing logging during metadata update timeout >

[jira] [Updated] (KAFKA-3691) Confusing logging during metadata update timeout

[ https://issues.apache.org/jira/browse/KAFKA-3691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3691: --- Fix Version/s: 0.10.1.0 > Confusing logging during metadata update timeout > -

[jira] [Updated] (KAFKA-3691) Confusing logging during metadata update timeout

[ https://issues.apache.org/jira/browse/KAFKA-3691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3691: --- Affects Version/s: 0.10.0.0 > Confusing logging during metadata update timeout > -

[jira] [Updated] (KAFKA-3691) Confusing logging during metadata update timeout

[ https://issues.apache.org/jira/browse/KAFKA-3691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3691: --- Fix Version/s: 0.10.0.1 > Confusing logging during metadata update timeout > -

[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: - Issue Type: Improvement (was: Bug) > Connect should parallelize task start/stop >

[jira] [Resolved] (KAFKA-2944) NullPointerException in KafkaConfigStorage when config storage starts right before shutdown request

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

[jira] [Updated] (KAFKA-2483) Add support for batch/scheduled Copycat connectors

[ https://issues.apache.org/jira/browse/KAFKA-2483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2483: - Issue Type: New Feature (was: Sub-task) Parent: (was: KAFKA-2365) > A

[jira] [Updated] (KAFKA-2483) Add support for batch/scheduled Copycat connectors

[ https://issues.apache.org/jira/browse/KAFKA-2483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2483: - Priority: Minor (was: Major) > Add support for batch/scheduled Copycat connectors

[GitHub] kafka pull request #1510: Minor: warn if the TGT cannot be renewed.

GitHub user harshach opened a pull request: https://github.com/apache/kafka/pull/1510 Minor: warn if the TGT cannot be renewed. You can merge this pull request into a Git repository by running: $ git pull https://github.com/harshach/kafka KerberosLogin-Log Alternatively you c

Re: [DISCUSS] KIP-4 Create Topic Schema

> Ewen's reply sums up my thoughts on the error handling points. It doesn't > seem ideal to justify the wire protocol behaviour based on the Java > implementation. If we need map-like semantics in the protocol, then maybe > we need a `Map` type to complement `Array`? Otherwise, I still think we > s

Re: [VOTE] KIP-55: Secure quotas for authenticated users

Rajini, How does sub-quotas works in case of authenticated users. Where are we maintaining the relation between users and their client Ids. Can you add an example of zk data under /users. Thanks, Harsha On Mon, Jun 13, 2016, at 05:01 AM, Rajini Sivaram wrote: > I have

[GitHub] kafka pull request #1498: KAFKA-3830; getTGT() debug logging exposes confide...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1498 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-3830) getTGT() debug logging exposes confidential information

[ https://issues.apache.org/jira/browse/KAFKA-3830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15332036#comment-15332036 ] ASF GitHub Bot commented on KAFKA-3830: --- Github user asfgit closed the pull request

[jira] [Updated] (KAFKA-3830) getTGT() debug logging exposes confidential information

[ https://issues.apache.org/jira/browse/KAFKA-3830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-3830: -- Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (wa

[jira] [Updated] (KAFKA-2376) Add Copycat metrics

[ https://issues.apache.org/jira/browse/KAFKA-2376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2376: - Issue Type: Improvement (was: Sub-task) Parent: (was: KAFKA-2365) > A

[jira] [Updated] (KAFKA-2378) Add Copycat embedded API

[ https://issues.apache.org/jira/browse/KAFKA-2378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2378: - Issue Type: New Feature (was: Sub-task) Parent: (was: KAFKA-2365) > A

Re: [DISCUSS] KIP-4 Create Topic Schema

Thanks for the feedback Ewen & Ismael. Fine about keeping replication_factor as INT32 (you mentioned 32k > partitions in your reply, but I was talking about replication_factor which > doesn't seem feasible to ever be that large. I didn't mention > num_partitions for the reason you mentioned). My

[jira] [Resolved] (KAFKA-2365) Copycat checklist

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

[jira] [Updated] (KAFKA-3254) Add Connect storage topic prefix for easier configuration

[ https://issues.apache.org/jira/browse/KAFKA-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3254: - Priority: Minor (was: Major) > Add Connect storage topic prefix for easier config

[jira] [Updated] (KAFKA-3106) After PUT a connector config from REST API, GET a connector config will fail

[ https://issues.apache.org/jira/browse/KAFKA-3106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3106: - Priority: Minor (was: Major) There are a few other ways we could handle this besi

[jira] [Updated] (KAFKA-3524) ConnectorTaskId should also also include cluster id

[ https://issues.apache.org/jira/browse/KAFKA-3524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3524: - Priority: Trivial (was: Major) > ConnectorTaskId should also also include cluster

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

[ https://issues.apache.org/jira/browse/KAFKA-3213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3213: - Priority: Critical (was: Major) > [CONNECT] It looks like we are not backing off

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

[ https://issues.apache.org/jira/browse/KAFKA-3213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3213: - Fix Version/s: 0.10.1.0 > [CONNECT] It looks like we are not backing off properly

[jira] [Updated] (KAFKA-3351) Kafka Connect Rest restarts all connectors on POST or DELETE

[ https://issues.apache.org/jira/browse/KAFKA-3351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3351: - Issue Type: Improvement (was: Bug) > Kafka Connect Rest restarts all connectors o

[jira] [Updated] (KAFKA-3759) Incorrect JDBC credentials cause Connect worker to permanently fail

[ https://issues.apache.org/jira/browse/KAFKA-3759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3759: - Fix Version/s: 0.10.1.0 > Incorrect JDBC credentials cause Connect worker to perma

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

[ https://issues.apache.org/jira/browse/KAFKA-3500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3500: - Priority: Critical (was: Major) > KafkaOffsetBackingStore set method needs to han

[jira] [Resolved] (KAFKA-3759) Incorrect JDBC credentials cause Connect worker to permanently fail

[ https://issues.apache.org/jira/browse/KAFKA-3759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3759. -- Resolution: Duplicate This seems to be a duplicate of KAFKA-3054. Also, we signi

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

[ https://issues.apache.org/jira/browse/KAFKA-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3734: - Priority: Critical (was: Major) > Exceptions in SourceTask.commit() methods shoul

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

[ https://issues.apache.org/jira/browse/KAFKA-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3734: - Fix Version/s: 0.10.1.0 > Exceptions in SourceTask.commit() methods should cause t

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

[ https://issues.apache.org/jira/browse/KAFKA-2894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2894: - Priority: Blocker (was: Major) Fix Version/s: 0.10.1.0 More generally, I

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

[ https://issues.apache.org/jira/browse/KAFKA-3782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3782: - Fix Version/s: 0.10.1.0 > Transient failure with > kafkatest.tests.connect.connec

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

[ https://issues.apache.org/jira/browse/KAFKA-3782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3782: - Priority: Minor (was: Major) > Transient failure with > kafkatest.tests.connect.

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

[ https://issues.apache.org/jira/browse/KAFKA-3782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15332134#comment-15332134 ] Ewen Cheslack-Postava commented on KAFKA-3782: -- Analysis elsewhere has shown

[jira] [Updated] (KAFKA-3813) Let SourceConnector implementations access the offset reader

[ https://issues.apache.org/jira/browse/KAFKA-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3813: - Issue Type: New Feature (was: Improvement) > Let SourceConnector implementations

[jira] [Updated] (KAFKA-3815) Support command line arguments in Kafka Connect distributed worker

[ https://issues.apache.org/jira/browse/KAFKA-3815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3815: - Priority: Minor (was: Major) > Support command line arguments in Kafka Connect di

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

[ https://issues.apache.org/jira/browse/KAFKA-3820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3820: - Priority: Minor (was: Major) > Provide utilities for tracking source offsets > --

[jira] [Updated] (KAFKA-3819) Provide utilities for polling source connectors

[ https://issues.apache.org/jira/browse/KAFKA-3819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3819: - Priority: Minor (was: Major) > Provide utilities for polling source connectors >

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

[ https://issues.apache.org/jira/browse/KAFKA-3487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3487: - Priority: Critical (was: Major) > Support per-connector/per-task classloaders in

[jira] [Updated] (KAFKA-3816) Provide more context in Kafka Connect log messages

[ https://issues.apache.org/jira/browse/KAFKA-3816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3816: - Priority: Critical (was: Major) > Provide more context in Kafka Connect log messa

[jira] [Updated] (KAFKA-3073) KafkaConnect should support regular expression for topics

[ https://issues.apache.org/jira/browse/KAFKA-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3073: - Fix Version/s: 0.10.1.0 > KafkaConnect should support regular expression for topic

[jira] [Updated] (KAFKA-3073) KafkaConnect should support regular expression for topics

[ https://issues.apache.org/jira/browse/KAFKA-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3073: - Issue Type: Improvement (was: Bug) > KafkaConnect should support regular expressi

[jira] [Updated] (KAFKA-2378) Add Copycat embedded API

[ https://issues.apache.org/jira/browse/KAFKA-2378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2378: - Fix Version/s: (was: 0.10.1.0) > Add Copycat embedded API > --

[jira] [Updated] (KAFKA-3209) Support single message transforms in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3209: - Fix Version/s: 0.10.1.0 > Support single message transforms in Kafka Connect > ---

[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: - Priority: Minor (was: Major) > Connect should parallelize task start/stop > -

[jira] [Updated] (KAFKA-3054) Connect Herder fail forever if sent a wrong connector config or task config

[ https://issues.apache.org/jira/browse/KAFKA-3054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3054: - Priority: Blocker (was: Major) Fix Version/s: 0.10.1.0 We improved error

Re: [VOTE] KIP-55: Secure quotas for authenticated users

Harsha, The sample configuration under https://cwiki.apache.org/confluence/display/KAFKA/KIP-55%3A+Secure+Quotas+for+Authenticated+Users#KIP-55:SecureQuotasforAuthenticatedUsers-QuotaConfiguration shows the Zookeeper data for different scenarios. - *user1* (/users/user1 in ZK) has only user-le

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

[ https://issues.apache.org/jira/browse/KAFKA-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2941: - Priority: Blocker (was: Minor) Bumping up the priority here as there's a seemingl

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

[ https://issues.apache.org/jira/browse/KAFKA-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2941: - Fix Version/s: 0.10.1.0 > Docs for key/value converter in Kafka connect are unclea

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

[ https://issues.apache.org/jira/browse/KAFKA-2925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15332159#comment-15332159 ] Ewen Cheslack-Postava commented on KAFKA-2925: -- [~hachikuji] Can you remember

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

[ https://issues.apache.org/jira/browse/KAFKA-2925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15332159#comment-15332159 ] Ewen Cheslack-Postava edited comment on KAFKA-2925 at 6/15/16 5:38 PM: -

[jira] [Updated] (KAFKA-3832) Kafka Connect's JSON Converter never outputs a null value

[ https://issues.apache.org/jira/browse/KAFKA-3832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3832: - Fix Version/s: 0.10.1.0 > Kafka Connect's JSON Converter never outputs a null valu

[jira] [Updated] (KAFKA-3209) Support single message transforms in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3209: - Priority: Critical (was: Major) > Support single message transforms in Kafka Conn

[jira] [Updated] (KAFKA-2483) Add support for batch/scheduled Copycat connectors

[ https://issues.apache.org/jira/browse/KAFKA-2483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2483: - Fix Version/s: (was: 0.10.1.0) > Add support for batch/scheduled Copycat conne

[jira] [Updated] (KAFKA-3351) Kafka Connect Rest restarts all connectors on POST or DELETE

[ https://issues.apache.org/jira/browse/KAFKA-3351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3351: - Fix Version/s: (was: 0.10.1.0) > Kafka Connect Rest restarts all connectors on

[jira] [Updated] (KAFKA-3845) Support per-connector converters

[ https://issues.apache.org/jira/browse/KAFKA-3845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3845: - Issue Type: Improvement (was: Bug) > Support per-connector converters > -

[jira] [Created] (KAFKA-3845) Support per-connector converters

Ewen Cheslack-Postava created KAFKA-3845: Summary: Support per-connector converters Key: KAFKA-3845 URL: https://issues.apache.org/jira/browse/KAFKA-3845 Project: Kafka Issue Type: Bu

[jira] [Created] (KAFKA-3846) Connect record types should include timestamps

Ewen Cheslack-Postava created KAFKA-3846: Summary: Connect record types should include timestamps Key: KAFKA-3846 URL: https://issues.apache.org/jira/browse/KAFKA-3846 Project: Kafka

[jira] [Updated] (KAFKA-3209) Support single message transforms in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3209: - Labels: needs-kip (was: ) > Support single message transforms in Kafka Connect >

[jira] [Updated] (KAFKA-3073) KafkaConnect should support regular expression for topics

[ https://issues.apache.org/jira/browse/KAFKA-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3073: - Labels: needs-kip (was: ) > KafkaConnect should support regular expression for to

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

[ https://issues.apache.org/jira/browse/KAFKA-3487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3487: - Labels: needs-kip (was: ) > Support per-connector/per-task classloaders in Connec

[jira] [Updated] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3821: - Labels: needs-kip (was: ) > Allow Kafka Connect source tasks to produce offset wi

[jira] [Updated] (KAFKA-3813) Let SourceConnector implementations access the offset reader

[ https://issues.apache.org/jira/browse/KAFKA-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3813: - Labels: needs-kip (was: ) > Let SourceConnector implementations access the offset

[jira] [Updated] (KAFKA-2376) Add Copycat metrics

[ https://issues.apache.org/jira/browse/KAFKA-2376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2376: - Labels: needs-kip (was: ) > Add Copycat metrics > --- > >

[jira] [Updated] (KAFKA-3254) Add Connect storage topic prefix for easier configuration

[ https://issues.apache.org/jira/browse/KAFKA-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3254: - Labels: needs-kip (was: ) > Add Connect storage topic prefix for easier configura

[jira] [Updated] (KAFKA-2378) Add Copycat embedded API

[ https://issues.apache.org/jira/browse/KAFKA-2378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2378: - Labels: needs-kip (was: ) > Add Copycat embedded API > >

[jira] [Updated] (KAFKA-3815) Support command line arguments in Kafka Connect distributed worker

[ https://issues.apache.org/jira/browse/KAFKA-3815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3815: - Labels: needs-kip (was: ) > Support command line arguments in Kafka Connect distr

[jira] [Updated] (KAFKA-2483) Add support for batch/scheduled Copycat connectors

[ https://issues.apache.org/jira/browse/KAFKA-2483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2483: - Labels: needs-kip (was: ) > Add support for batch/scheduled Copycat connectors >

[jira] [Updated] (KAFKA-3819) Provide utilities for polling source connectors

[ https://issues.apache.org/jira/browse/KAFKA-3819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3819: - Labels: needs-kip (was: ) > Provide utilities for polling source connectors > ---

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

[ https://issues.apache.org/jira/browse/KAFKA-3820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3820: - Labels: needs-kip (was: ) > Provide utilities for tracking source offsets > -

[jira] [Updated] (KAFKA-3400) Topic stop working / can't describe topic

[ https://issues.apache.org/jira/browse/KAFKA-3400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3400: -- Resolution: Cannot Reproduce Status: Resolved (was: Patch Available) Resolving this as

[jira] [Created] (KAFKA-3847) Connect tasks should not share a producer

Ewen Cheslack-Postava created KAFKA-3847: Summary: Connect tasks should not share a producer Key: KAFKA-3847 URL: https://issues.apache.org/jira/browse/KAFKA-3847 Project: Kafka Issue

[jira] [Updated] (KAFKA-3543) Allow a variant of transform() which can emit multiple values

[ https://issues.apache.org/jira/browse/KAFKA-3543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3543: - Assignee: (was: Guozhang Wang) > Allow a variant of transform() which can emit multiple values

[jira] [Updated] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3729: - Assignee: (was: Guozhang Wang) > Auto-configure non-default SerDes passed alongside the topol

[jira] [Updated] (KAFKA-3708) Rethink exception handling in KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3708: - Assignee: (was: Guozhang Wang) > Rethink exception handling in KafkaStreams >

[jira] [Updated] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3729: - Labels: api newbie (was: api) > Auto-configure non-default SerDes passed alongside the topology

[jira] [Updated] (KAFKA-3770) KStream job should be able to specify linger.ms

[ https://issues.apache.org/jira/browse/KAFKA-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3770: - Assignee: Greg Fodor (was: Guozhang Wang) > KStream job should be able to specify linger.ms > ---

[jira] [Updated] (KAFKA-3741) KStream config for changelog min.in.sync.replicas

[ https://issues.apache.org/jira/browse/KAFKA-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3741: - Assignee: (was: Guozhang Wang) > KStream config for changelog min.in.sync.replicas > -

[jira] [Updated] (KAFKA-3576) Unify KStream and KTable API

[ https://issues.apache.org/jira/browse/KAFKA-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3576: - Assignee: Damian Guy (was: Guozhang Wang) > Unify KStream and KTable API > --

[jira] [Updated] (KAFKA-3752) Provide a way for KStreams to recover from unclean shutdown

[ https://issues.apache.org/jira/browse/KAFKA-3752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3752: - Assignee: (was: Guozhang Wang) > Provide a way for KStreams to recover from unclean shutdown >

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

[ https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3595: - Assignee: (was: Guozhang Wang) > Add capability to specify replication compact option for stre

[jira] [Updated] (KAFKA-3545) Generalized Serdes for List/Map

[ https://issues.apache.org/jira/browse/KAFKA-3545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3545: - Assignee: (was: Guozhang Wang) > Generalized Serdes for List/Map > ---

[jira] [Updated] (KAFKA-3545) Generalized Serdes for List/Map

[ https://issues.apache.org/jira/browse/KAFKA-3545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3545: - Labels: api newbie (was: api) > Generalized Serdes for List/Map > ---

[jira] [Updated] (KAFKA-3535) Add metrics ability for streams serde components

[ https://issues.apache.org/jira/browse/KAFKA-3535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3535: - Assignee: (was: Guozhang Wang) > Add metrics ability for streams serde components > --

[jira] [Updated] (KAFKA-3836) KStreamReduce and KTableReduce should not pass nulls to Deserializers

[ https://issues.apache.org/jira/browse/KAFKA-3836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3836: - Assignee: (was: Guozhang Wang) > KStreamReduce and KTableReduce should not pass nulls to Deser

  1   2   >