[jira] [Created] (KAFKA-3424) Add CORS support to Connect REST API

Ewen Cheslack-Postava created KAFKA-3424: Summary: Add CORS support to Connect REST API Key: KAFKA-3424 URL: https://issues.apache.org/jira/browse/KAFKA-3424 Project: Kafka Issue

[jira] [Resolved] (KAFKA-3423) can't start kafka connect with former configs in distributed mode

[ https://issues.apache.org/jira/browse/KAFKA-3423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3423. -- Resolution: Duplicate Reviewer: Ewen Cheslack-Postava Thanks for the

[jira] [Commented] (KAFKA-3290) WorkerSourceTask testCommit transient failure

[ https://issues.apache.org/jira/browse/KAFKA-3290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15196767#comment-15196767 ] Ewen Cheslack-Postava commented on KAFKA-3290: -- This was reopened because it seemed to be

[jira] [Resolved] (KAFKA-3260) Increase the granularity of commit for SourceTask

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

[jira] [Updated] (KAFKA-3315) Add Connect API to expose connector configuration info

[ https://issues.apache.org/jira/browse/KAFKA-3315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3315: - Status: Patch Available (was: Open) https://github.com/apache/kafka/pull/964 >

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

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

[jira] [Created] (KAFKA-3384) bin scripts may not be portable/POSIX compliant

Ewen Cheslack-Postava created KAFKA-3384: Summary: bin scripts may not be portable/POSIX compliant Key: KAFKA-3384 URL: https://issues.apache.org/jira/browse/KAFKA-3384 Project: Kafka

[jira] [Updated] (KAFKA-3344) Remove previous system test's leftover test-log4j.properties

[ https://issues.apache.org/jira/browse/KAFKA-3344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3344: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

[jira] [Updated] (KAFKA-3335) Kafka Connect hangs in shutdown hook

[ https://issues.apache.org/jira/browse/KAFKA-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3335: - Component/s: copycat > Kafka Connect hangs in shutdown hook >

[jira] [Updated] (KAFKA-3279) SASL implementation checks for unused System property java.security.auth.login.config

[ https://issues.apache.org/jira/browse/KAFKA-3279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3279: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

[jira] [Updated] (KAFKA-3237) ConfigDef validators require a default value

[ https://issues.apache.org/jira/browse/KAFKA-3237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3237: - Assignee: Jeremy Custenborder > ConfigDef validators require a default value >

[jira] [Resolved] (KAFKA-3237) ConfigDef validators require a default value

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

[jira] [Updated] (KAFKA-3201) Add system test for KIP-31 and KIP-32 - Upgrade Test

[ https://issues.apache.org/jira/browse/KAFKA-3201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3201: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

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

[ https://issues.apache.org/jira/browse/KAFKA-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2914. -- Resolution: Won't Fix [~apurtell] Thanks for the link. I'm going to mark this

[jira] [Updated] (KAFKA-3299) KafkaConnect: DistributedHerder shouldn't wait forever to read configs after rebalance

[ https://issues.apache.org/jira/browse/KAFKA-3299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3299: - Assignee: Gwen Shapira > KafkaConnect: DistributedHerder shouldn't wait forever

[jira] [Resolved] (KAFKA-3299) KafkaConnect: DistributedHerder shouldn't wait forever to read configs after rebalance

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

[jira] [Resolved] (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:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2934. -- Resolution: Fixed Fix Version/s: 0.10.0.0 Issue resolved by pull request

[jira] [Resolved] (KAFKA-3324) NullPointerException in StreamPartitionAssignor (Kafka Streams)

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

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

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

[jira] [Updated] (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 updated KAFKA-2944: - Assignee: Gwen Shapira (was: Ewen Cheslack-Postava) > NullPointerException in

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

[ https://issues.apache.org/jira/browse/KAFKA-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3316: - Priority: Blocker (was: Major) > Add Connect REST API to list available

[jira] [Updated] (KAFKA-2370) Add pause/unpause connector support

[ https://issues.apache.org/jira/browse/KAFKA-2370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2370: - Priority: Blocker (was: Major) > Add pause/unpause connector support >

[jira] [Updated] (KAFKA-3315) Add Connect API to expose connector configuration info

[ https://issues.apache.org/jira/browse/KAFKA-3315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3315: - Priority: Blocker (was: Major) > Add Connect API to expose connector

[jira] [Resolved] (KAFKA-3257) bootstrap-test-env.sh version check fails when grep has --colour option enabled.

[ https://issues.apache.org/jira/browse/KAFKA-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3257. -- Resolution: Fixed Issue resolved by pull request 969

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

Ewen Cheslack-Postava created KAFKA-3316: Summary: Add Connect REST API to list available connector classes Key: KAFKA-3316 URL: https://issues.apache.org/jira/browse/KAFKA-3316 Project: Kafka

[jira] [Created] (KAFKA-3315) Add Connect API to expose connector configuration info

Ewen Cheslack-Postava created KAFKA-3315: Summary: Add Connect API to expose connector configuration info Key: KAFKA-3315 URL: https://issues.apache.org/jira/browse/KAFKA-3315 Project: Kafka

[jira] [Commented] (KAFKA-3290) WorkerSourceTask testCommit transient failure

[ https://issues.apache.org/jira/browse/KAFKA-3290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15175150#comment-15175150 ] Ewen Cheslack-Postava commented on KAFKA-3290: -- [~hachikuji] Did you reproduce this locally?

[jira] [Updated] (KAFKA-3243) Fix Kafka basic ops documentation for Mirror maker, blacklist is not supported for new consumers

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

[jira] [Reopened] (KAFKA-3277) Update trunk version to be 0.10.0.0-SNAPSHOT

[ https://issues.apache.org/jira/browse/KAFKA-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reopened KAFKA-3277: -- > Update trunk version to be 0.10.0.0-SNAPSHOT >

[jira] [Updated] (KAFKA-3277) Update trunk version to be 0.10.0.0-SNAPSHOT

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

[jira] [Resolved] (KAFKA-3276) Rename 0.10.0.0 to 0.10.1.0 and 0.9.1.0 to 0.10.0.0 in JIRA

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

[jira] [Updated] (KAFKA-3276) Rename 0.10.0.0 to 0.10.1.0 and 0.9.1.0 to 0.10.0.0 in JIRA

[ https://issues.apache.org/jira/browse/KAFKA-3276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3276: - Fix Version/s: 0.10.1.0 > Rename 0.10.0.0 to 0.10.1.0 and 0.9.1.0 to 0.10.0.0 in

[jira] [Resolved] (KAFKA-3093) Keep track of connector and task status info, expose it via the REST API

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

[jira] [Commented] (KAFKA-1196) java.lang.IllegalArgumentException Buffer.limit on FetchResponse.scala + 33

[ https://issues.apache.org/jira/browse/KAFKA-1196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15160213#comment-15160213 ] Ewen Cheslack-Postava commented on KAFKA-1196: -- [~ijuma] Pretty sure I didn't set the fix

[jira] [Commented] (KAFKA-3273) MessageFormatter and MessageReader interfaces should be resilient to changes

[ https://issues.apache.org/jira/browse/KAFKA-3273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15159899#comment-15159899 ] Ewen Cheslack-Postava commented on KAFKA-3273: -- To clarify my thoughts, I don't think these

[jira] [Resolved] (KAFKA-3007) Implement max.poll.records for new consumer (KIP-41)

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

[jira] [Resolved] (KAFKA-2802) Add integration tests for Kafka Streams

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

[jira] [Updated] (KAFKA-2802) Add integration tests for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2802: - Assignee: Yasuhiro Matsuda > Add integration tests for Kafka Streams >

[jira] [Updated] (KAFKA-3255) Extra unit tests for NetworkClient.connectionDelay(Node node, long now)

[ https://issues.apache.org/jira/browse/KAFKA-3255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3255: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

[jira] [Resolved] (KAFKA-3225) Method commit() of class SourceTask never invoked

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

[jira] [Resolved] (KAFKA-3227) Conservative update of Kafka dependencies

[ https://issues.apache.org/jira/browse/KAFKA-3227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3227. -- Resolution: Fixed Issue resolved by pull request 903

[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=15139836#comment-15139836 ] Ewen Cheslack-Postava commented on KAFKA-2375: -- [~arttii] Great to hear you're working on

[jira] [Updated] (KAFKA-3189) Kafka server returns UnknownServerException for inherited exceptions

[ https://issues.apache.org/jira/browse/KAFKA-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3189: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

[jira] [Updated] (KAFKA-3217) Unit tests which dont close producers auto-create topics in Kafka brokers of other tests when port is reused

[ https://issues.apache.org/jira/browse/KAFKA-3217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3217: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

[jira] [Updated] (KAFKA-3191) Improve offset committing JavaDoc in KafkaConsumer

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

[jira] [Commented] (KAFKA-3055) JsonConverter mangles schema during serialization (fromConnectData)

[ https://issues.apache.org/jira/browse/KAFKA-3055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15138155#comment-15138155 ] Ewen Cheslack-Postava commented on KAFKA-3055: -- There's a config schemas.cache.size. Since

[jira] [Updated] (KAFKA-3165) Fix ignored parameters in the gradle "All" tasks

[ https://issues.apache.org/jira/browse/KAFKA-3165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3165: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

[jira] [Updated] (KAFKA-2589) Documentation bug: the default value for the "rebalance.backoff.ms" property is not specified correctly

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

[jira] [Updated] (KAFKA-3037) Number of alive brokers not known after single node cluster startup

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

[jira] [Resolved] (KAFKA-3092) Rename SinkTask.onPartitionsAssigned/onPartitionsRevoked and Clarify Contract

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

[jira] [Resolved] (KAFKA-3121) KStream DSL API Improvement

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

[jira] [Created] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

Ewen Cheslack-Postava created KAFKA-3195: Summary: Transient test failure in OffsetCheckpointTest.testReadWrite Key: KAFKA-3195 URL: https://issues.apache.org/jira/browse/KAFKA-3195 Project:

[jira] [Updated] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

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

[jira] [Updated] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

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

[jira] [Updated] (KAFKA-3060) Refactor MeteredXXStore

[ https://issues.apache.org/jira/browse/KAFKA-3060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3060: - Assignee: Guozhang Wang > Refactor MeteredXXStore > --- > >

[jira] [Resolved] (KAFKA-3060) Refactor MeteredXXStore

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

[jira] [Updated] (KAFKA-3029) Make class org.apache.kafka.common.TopicPartition Serializable

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

[jira] [Updated] (KAFKA-3029) Make class org.apache.kafka.common.TopicPartition Serializable

[ https://issues.apache.org/jira/browse/KAFKA-3029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3029: - Fix Version/s: 0.9.0.1 > Make class org.apache.kafka.common.TopicPartition

[jira] [Updated] (KAFKA-3029) Make class org.apache.kafka.common.TopicPartition Serializable

[ https://issues.apache.org/jira/browse/KAFKA-3029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3029: - Assignee: Praveen Devarao > Make class org.apache.kafka.common.TopicPartition

[jira] [Resolved] (KAFKA-3125) Exception Hierarchy for Streams

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

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15116465#comment-15116465 ] Ewen Cheslack-Postava commented on KAFKA-3068: -- [~junrao] Right, for people using VIP or DNS,

[jira] [Updated] (KAFKA-3138) 0.9.0 docs still say that log compaction doesn't work on compressed topics.

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

[jira] [Resolved] (KAFKA-3023) Log Compaction documentation still says compressed messages are not supported

[ https://issues.apache.org/jira/browse/KAFKA-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3023. -- Resolution: Duplicate > Log Compaction documentation still says compressed

[jira] [Resolved] (KAFKA-3134) Missing required configuration "value.deserializer" when initializing a KafkaConsumer with a valid "valueDeserializer"

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

[jira] [Commented] (KAFKA-3023) Log Compaction documentation still says compressed messages are not supported

[ https://issues.apache.org/jira/browse/KAFKA-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15114261#comment-15114261 ] Ewen Cheslack-Postava commented on KAFKA-3023: -- Marking dup of newer bug since KAFKA-3138 has

[jira] [Resolved] (KAFKA-2846) Add Ducktape test for kafka-consumer-groups

[ https://issues.apache.org/jira/browse/KAFKA-2846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2846. -- Resolution: Fixed Issue resolved by pull request 555

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112863#comment-15112863 ] Ewen Cheslack-Postava commented on KAFKA-3068: -- [~enothereska] [~ijuma] Agreed, likely a KIP

[jira] [Commented] (KAFKA-3061) Get rid of Guava dependency

[ https://issues.apache.org/jira/browse/KAFKA-3061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112729#comment-15112729 ] Ewen Cheslack-Postava commented on KAFKA-3061: -- [~ijuma] I think they could if they could as

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112787#comment-15112787 ] Ewen Cheslack-Postava commented on KAFKA-3068: -- I'm thinking more about this in combination

[jira] [Resolved] (KAFKA-3066) Add Demo Examples for Kafka Streams

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

[jira] [Updated] (KAFKA-2071) Replace Produce Request/Response with their org.apache.kafka.common.requests equivalents

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

[jira] [Updated] (KAFKA-3105) Use `Utils.atomicMoveWithFallback` instead of `File.rename`

[ https://issues.apache.org/jira/browse/KAFKA-3105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3105: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

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

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

[jira] [Commented] (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:comment-tabpanel=15098458#comment-15098458 ] Ewen Cheslack-Postava commented on KAFKA-3106: -- Rebalances are going to be pretty expensive

[jira] [Resolved] (KAFKA-3069) Fix recursion in ZkSecurityMigrator

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

[jira] [Commented] (KAFKA-3092) Rename SinkTask.onPartitionsAssigned/onPartitionsRevoked and Clarify Contract

[ https://issues.apache.org/jira/browse/KAFKA-3092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15095314#comment-15095314 ] Ewen Cheslack-Postava commented on KAFKA-3092: -- The change to rename to open/close and fix up

[jira] [Updated] (KAFKA-3063) LogRecoveryTest exits with -1 occasionally

[ https://issues.apache.org/jira/browse/KAFKA-3063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3063: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

[jira] [Commented] (KAFKA-3092) Rename SinkTask.onPartitionsAssigned/onPartitionsRevoked and Clarify Contract

[ https://issues.apache.org/jira/browse/KAFKA-3092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15095445#comment-15095445 ] Ewen Cheslack-Postava commented on KAFKA-3092: -- Yes, those are exactly the semantics I was

[jira] [Updated] (KAFKA-3021) Centralize dependency version managment

[ https://issues.apache.org/jira/browse/KAFKA-3021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3021: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

[jira] [Resolved] (KAFKA-3077) Enable KafkaLog4jAppender to work with SASL enabled brokers.

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

[jira] [Resolved] (KAFKA-3078) Add ducktape tests for KafkaLog4jAppender producing to SASL enabled Kafka cluster

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

[jira] [Updated] (KAFKA-3084) Topic existence checks in topic commands (create, alter, delete)

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

[jira] [Commented] (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:comment-tabpanel=15092392#comment-15092392 ] Ewen Cheslack-Postava commented on KAFKA-3054: -- [~jinxing6...@126.com] We do want to catch

[jira] [Updated] (KAFKA-3019) Add an exceptionName method to Errors

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

[jira] [Resolved] (KAFKA-3044) Consumer.poll doesnot return messages when poll interval is less

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

[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: - Component/s: copycat > KafkaConnect should support regular expression for topics

[jira] [Resolved] (KAFKA-2979) Enable authorizer and ACLs in ducktape tests

[ https://issues.apache.org/jira/browse/KAFKA-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2979. -- Resolution: Fixed Issue resolved by pull request 683

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15088200#comment-15088200 ] Ewen Cheslack-Postava commented on KAFKA-3068: -- [~junrao] It's definitely a real issue -- see

[jira] [Created] (KAFKA-3074) Regex sink connector support

Ewen Cheslack-Postava created KAFKA-3074: Summary: Regex sink connector support Key: KAFKA-3074 URL: https://issues.apache.org/jira/browse/KAFKA-3074 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-2884) Schema cache corruption in JsonConverter

[ https://issues.apache.org/jira/browse/KAFKA-2884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2884. -- Resolution: Duplicate Oops, seems when KAFKA-3055 was filed we missed that we

[jira] [Resolved] (KAFKA-2422) Allow copycat connector plugins to be aliased to simpler names

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

[jira] [Resolved] (KAFKA-3055) JsonConverter mangles schema during serialization (fromConnectData)

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

[jira] [Commented] (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:comment-tabpanel=15081370#comment-15081370 ] Ewen Cheslack-Postava commented on KAFKA-3054: -- [~jinxing6...@126.com] Yes, this sounds like

[jira] [Resolved] (KAFKA-3002) Make available to specify hostname with Uppercase at broker list

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

[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=15070331#comment-15070331 ] Ewen Cheslack-Postava commented on KAFKA-3006: -- So, now I'm not sure what conclusion we've

[jira] [Commented] (KAFKA-3011) Consumer.poll(0) blocks if Kafka not accessible

[ https://issues.apache.org/jira/browse/KAFKA-3011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15070305#comment-15070305 ] Ewen Cheslack-Postava commented on KAFKA-3011: -- [~ebowman] I think this is a duplicate of

[jira] [Resolved] (KAFKA-2989) Verify all partitions consumed after rebalancing in system tests

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

[jira] [Updated] (KAFKA-3009) Disallow star imports

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

[jira] [Updated] (KAFKA-3020) Ensure Checkstyle runs on all Java code

[ https://issues.apache.org/jira/browse/KAFKA-3020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3020: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

[jira] [Updated] (KAFKA-269) ./system_test/producer_perf/bin/run-test.sh without --async flag does not run

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

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