[jira] [Created] (KAFKA-3464) Connect security system tests

Ewen Cheslack-Postava created KAFKA-3464: Summary: Connect security system tests Key: KAFKA-3464 URL: https://issues.apache.org/jira/browse/KAFKA-3464 Project: Kafka Issue Type: Bug

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

Ewen Cheslack-Postava created KAFKA-3459: Summary: Returning zero task configurations from a connector does not properly clean up existing tasks Key: KAFKA-3459 URL: https://issues.apache.org/jira/browse/K

[jira] [Resolved] (KAFKA-3407) ErrorLoggingCallback trims helpful diagnostic information.

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

[jira] [Updated] (KAFKA-3445) ConnectorConfig should validate TASKS_MAX_CONFIG's lower bound limit

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

[jira] [Commented] (KAFKA-3445) ConnectorConfig should validate TASKS_MAX_CONFIG's lower bound limit

[ https://issues.apache.org/jira/browse/KAFKA-3445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15209863#comment-15209863 ] Ewen Cheslack-Postava commented on KAFKA-3445: -- [~Ryan P] Not nit picky at al

[jira] [Commented] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15209825#comment-15209825 ] Ewen Cheslack-Postava commented on KAFKA-2939: -- Probably worth thinking throu

[jira] [Updated] (KAFKA-3434) Add old ConsumerRecord constructor for compatibility

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

[jira] [Created] (KAFKA-3453) Transient test failures due to MiniKDC port allocation strategy

Ewen Cheslack-Postava created KAFKA-3453: Summary: Transient test failures due to MiniKDC port allocation strategy Key: KAFKA-3453 URL: https://issues.apache.org/jira/browse/KAFKA-3453 Project

[jira] [Commented] (KAFKA-3404) Issues running the kafka system test Sasl

[ https://issues.apache.org/jira/browse/KAFKA-3404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207551#comment-15207551 ] Ewen Cheslack-Postava commented on KAFKA-3404: -- [~mimaison] Can you check tha

[jira] [Resolved] (KAFKA-3412) Multiple commitAsync() calls causes SendFailedException in commit callback

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

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205083#comment-15205083 ] Ewen Cheslack-Postava commented on KAFKA-1173: -- [~gwenshap] Maybe? I had been

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203558#comment-15203558 ] Ewen Cheslack-Postava commented on KAFKA-1173: -- [~sfgower] Those instructions

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

[ https://issues.apache.org/jira/browse/KAFKA-3424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3424: - Status: Patch Available (was: Open) > Add CORS support to Connect REST API >

[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: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

[jira] [Resolved] (KAFKA-3371) ClientCompatibilityTest system test failing since KIP-31/KIP-32 was merged

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

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

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

[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&focusedCommentId=15196767#comment-15196767 ] Ewen Cheslack-Postava commented on KAFKA-3290: -- This was reopened because it

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

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

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

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

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

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

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

[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 [https://github.com/apache/

[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&focusedCommentId=15175150#comment-15175150 ] Ewen Cheslack-Postava commented on KAFKA-3290: -- [~hachikuji] Did you reproduc

[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 (was:

[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] [Resolved] (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 resolved KAFKA-3277. -- Resolution: Fixed > 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) 0.10

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

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

[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&focusedCommentId=15160213#comment-15160213 ] Ewen Cheslack-Postava commented on KAFKA-1196: -- [~ijuma] Pretty sure I didn't

[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&focusedCommentId=15159899#comment-15159899 ] Ewen Cheslack-Postava commented on KAFKA-3273: -- To clarify my thoughts, I don

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

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

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

[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 [https://github.com/apache/

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

[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] [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&focusedCommentId=15138155#comment-15138155 ] Ewen Cheslack-Postava commented on KAFKA-3055: -- There's a config schemas.cach

[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] [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] [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] [Resolved] (KAFKA-3211) Handle Connect WorkerTask shutdown before startup correctly

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

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

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

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

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

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

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

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

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

[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&focusedCommentId=15116465#comment-15116465 ] Ewen Cheslack-Postava commented on KAFKA-3068: -- [~junrao] Right, for people u

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

[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&focusedCommentId=15114261#comment-15114261 ] Ewen Cheslack-Postava commented on KAFKA-3023: -- Marking dup of newer bug sinc

[jira] [Commented] (KAFKA-2426) A Kafka node tries to connect to itself through its advertised hostname

[ https://issues.apache.org/jira/browse/KAFKA-2426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15114260#comment-15114260 ] Ewen Cheslack-Postava commented on KAFKA-2426: -- Although it should be *very*

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

[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 [https://github.com/apache/

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

[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&focusedCommentId=15112863#comment-15112863 ] Ewen Cheslack-Postava commented on KAFKA-3068: -- [~enothereska] [~ijuma] Agree

[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&focusedCommentId=15112787#comment-15112787 ] Ewen Cheslack-Postava commented on KAFKA-3068: -- I'm thinking more about this

[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&focusedCommentId=15112729#comment-15112729 ] Ewen Cheslack-Postava commented on KAFKA-3061: -- [~ijuma] I think they could i

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

[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&focusedCommentId=15098458#comment-15098458 ] Ewen Cheslack-Postava commented on KAFKA-3106: -- Rebalances are going to be pr

[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&focusedCommentId=15095445#comment-15095445 ] Ewen Cheslack-Postava commented on KAFKA-3092: -- Yes, those are exactly the se

[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&focusedCommentId=15095314#comment-15095314 ] Ewen Cheslack-Postava commented on KAFKA-3092: -- The change to rename to open/

[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] [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) 0.9

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

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

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

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