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

Gwen Shapira created KAFKA-3421: --- Summary: Update docs with new connector features Key: KAFKA-3421 URL: https://issues.apache.org/jira/browse/KAFKA-3421 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-2832) support exclude.internal.topics in new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2832: Reviewer: Gwen Shapira > support exclude.internal.topics in new consumer >

[jira] [Updated] (KAFKA-3414) Return of MetadataCache.getAliveBrokers should not be mutated by cache updates

[ https://issues.apache.org/jira/browse/KAFKA-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3414: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-3336) Unify ser/de pair classes into one serde class

[ https://issues.apache.org/jira/browse/KAFKA-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3336: Reviewer: Gwen Shapira > Unify ser/de pair classes into one serde class >

[jira] [Updated] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

[ https://issues.apache.org/jira/browse/KAFKA-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3378: Assignee: Larkin Lowrey > Client blocks forever if SocketChannel connects instantly >

[jira] [Updated] (KAFKA-3250) release tarball is unnecessarily large due to duplicate libraries

[ https://issues.apache.org/jira/browse/KAFKA-3250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3250: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-3403) Upgrade ZkClient to 0.8

[ https://issues.apache.org/jira/browse/KAFKA-3403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3403: Priority: Critical (was: Major) Reviewer: Flavio Junqueira > Upgrade ZkClient to 0.8 >

[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=15198369#comment-15198369 ] Gwen Shapira commented on KAFKA-3410: - 2. You are right. We can use this JIRA to track the fix. >

[jira] [Commented] (KAFKA-3413) Load Error Message should be a Warning

[ https://issues.apache.org/jira/browse/KAFKA-3413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197861#comment-15197861 ] Gwen Shapira commented on KAFKA-3413: - This is an error due to the severe implications - on a replica,

[jira] [Updated] (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 ] Gwen Shapira updated KAFKA-3412: Priority: Blocker (was: Major) Reviewer: Ewen Cheslack-Postava Marking as blocker, since it is

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

[ https://issues.apache.org/jira/browse/KAFKA-3421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3421: Reviewer: Gwen Shapira > Update docs with new connector features >

[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=15198321#comment-15198321 ] Gwen Shapira commented on KAFKA-3410: - 1. Broker 2 couldn't have been the leader since it was out of

[jira] [Resolved] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3202. - Resolution: Fixed Issue resolved by pull request 1070 [https://github.com/apache/kafka/pull/1070]

[jira] [Updated] (KAFKA-2832) support exclude.internal.topics in new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2832: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (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 ] Gwen Shapira updated KAFKA-3412: Fix Version/s: 0.10.0.0 > Multiple commitAsync() calls causes SendFailedException in commit

[jira] [Updated] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

[ https://issues.apache.org/jira/browse/KAFKA-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3378: Status: Patch Available (was: Open) > Client blocks forever if SocketChannel connects instantly >

[jira] [Updated] (KAFKA-3328) SimpleAclAuthorizer can lose ACLs with frequent add/remove calls

[ https://issues.apache.org/jira/browse/KAFKA-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3328: Reviewer: Flavio Junqueira > SimpleAclAuthorizer can lose ACLs with frequent add/remove calls >

[jira] [Updated] (KAFKA-3425) Add KIP-45 note to upgrade docs

[ https://issues.apache.org/jira/browse/KAFKA-3425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3425: Priority: Blocker (was: Major) > Add KIP-45 note to upgrade docs > ---

[jira] [Updated] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

[ https://issues.apache.org/jira/browse/KAFKA-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3378: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (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:all-tabpanel ] Gwen Shapira updated KAFKA-3006: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-3336) Unify ser/de pair classes into one serde class

[ https://issues.apache.org/jira/browse/KAFKA-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3336: Status: Patch Available (was: Open) > Unify ser/de pair classes into one serde class >

[jira] [Updated] (KAFKA-3013) Display the topic-partition in the exception message for expired batches in recordAccumulator

[ https://issues.apache.org/jira/browse/KAFKA-3013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3013: Resolution: Fixed Fix Version/s: 0.10.0.0 Status: Resolved (was: Patch Available)

[jira] [Updated] (KAFKA-3375) Suppress and fix compiler warnings where reasonable and tweak compiler settings

[ https://issues.apache.org/jira/browse/KAFKA-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3375: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3373: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-3380) Add system test for GetOffsetShell tool

[ https://issues.apache.org/jira/browse/KAFKA-3380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3380: Resolution: Fixed Fix Version/s: 0.10.0.0 Status: Resolved (was: Patch Available)

[jira] [Updated] (KAFKA-2073) Replace TopicMetadata request/response with o.a.k.requests.metadata

[ https://issues.apache.org/jira/browse/KAFKA-2073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2073: Resolution: Fixed Status: Resolved (was: Patch Available) > Replace TopicMetadata

[jira] [Resolved] (KAFKA-3318) Improve consumer rebalance error messaging

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

[jira] [Commented] (KAFKA-3361) Initial protocol documentation page and generation

[ https://issues.apache.org/jira/browse/KAFKA-3361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15189720#comment-15189720 ] Gwen Shapira commented on KAFKA-3361: - merged. Sorry for accidentally breaking the build :( > Initial

[jira] [Updated] (KAFKA-3357) Update to Scala 2.11.8

[ https://issues.apache.org/jira/browse/KAFKA-3357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3357: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Resolved] (KAFKA-3354) Streams system tests fail in trunk

[ https://issues.apache.org/jira/browse/KAFKA-3354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3354. - Resolution: Fixed Assignee: Guozhang Wang > Streams system tests fail in trunk >

[jira] [Comment Edited] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka

[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15188187#comment-15188187 ] Gwen Shapira edited comment on KAFKA-3355 at 3/9/16 10:28 PM: -- If you think

[jira] [Commented] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka

[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15188187#comment-15188187 ] Gwen Shapira commented on KAFKA-3355: - If you think you will finish by 0.10.0, go for it. >

[jira] [Updated] (KAFKA-3352) Avoid DNS reverse lookups

[ https://issues.apache.org/jira/browse/KAFKA-3352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3352: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Commented] (KAFKA-3369) Add unit-tests to the Metadata Cache

[ https://issues.apache.org/jira/browse/KAFKA-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15188053#comment-15188053 ] Gwen Shapira commented on KAFKA-3369: - I'll check after reviewing the PR and perhaps close this

[jira] [Created] (KAFKA-3369) Add unit-tests to the Metadata Cache

Gwen Shapira created KAFKA-3369: --- Summary: Add unit-tests to the Metadata Cache Key: KAFKA-3369 URL: https://issues.apache.org/jira/browse/KAFKA-3369 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-3323) Negative offsets in Log Segment Index files due to Integer overflow when compaction is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15185766#comment-15185766 ] Gwen Shapira commented on KAFKA-3323: - You rock! Thank you. > Negative offsets in Log Segment Index

[jira] [Commented] (KAFKA-3323) Negative offsets in Log Segment Index files due to Integer overflow when compaction is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15185624#comment-15185624 ] Gwen Shapira commented on KAFKA-3323: - [~michael.schiff] Yeah, i was thinking that you can host this

[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 ] Gwen Shapira updated KAFKA-3351: Reviewer: Gwen Shapira Fix Version/s: 0.10.0.0 > Kafka Connect Rest restarts all

[jira] [Updated] (KAFKA-3047) Explicit offset assignment in Log.append can corrupt the log

[ https://issues.apache.org/jira/browse/KAFKA-3047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3047: Priority: Blocker (was: Major) > Explicit offset assignment in Log.append can corrupt the log >

[jira] [Updated] (KAFKA-2024) Cleaner can generate unindexable log segments

[ https://issues.apache.org/jira/browse/KAFKA-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2024: Fix Version/s: 0.9.0.0 > Cleaner can generate unindexable log segments >

[jira] [Commented] (KAFKA-2163) Offsets manager cache should prevent stale-offset-cleanup while an offset load is in progress; otherwise we can lose consumer offsets

[ https://issues.apache.org/jira/browse/KAFKA-2163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15185164#comment-15185164 ] Gwen Shapira commented on KAFKA-2163: - We are no longer merging into 0.8.2 branch because we are not

[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 ] Gwen Shapira updated KAFKA-3351: Assignee: Jason Gustafson (was: Ewen Cheslack-Postava) > Kafka Connect Rest restarts all

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

[ https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15184345#comment-15184345 ] Gwen Shapira commented on KAFKA-2967: - We are using Gradle to package the release, and it also runs

[jira] [Updated] (KAFKA-2069) Replace OffsetFetch request/response with their org.apache.kafka.common.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2069: Resolution: Fixed Fix Version/s: 0.10.0.0 Status: Resolved (was: Patch Available)

[jira] [Updated] (KAFKA-2068) Replace OffsetCommit Request/Response with org.apache.kafka.common.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2068: Resolution: Fixed Fix Version/s: 0.10.0.0 Status: Resolved (was: Patch Available)

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

[ https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15184231#comment-15184231 ] Gwen Shapira commented on KAFKA-2967: - Thanks for the work [~ceposta]! Is there any way to integrate

[jira] [Commented] (KAFKA-3348) Add system tests for upgrade from 0.9.1.0 to 0.10.0.0

[ https://issues.apache.org/jira/browse/KAFKA-3348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15184141#comment-15184141 ] Gwen Shapira commented on KAFKA-3348: - 1. We also need to test 0.8.X upgrades 2. We already have

[jira] [Commented] (KAFKA-3346) Rename "Mode" to "SslMode"

[ https://issues.apache.org/jira/browse/KAFKA-3346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15184139#comment-15184139 ] Gwen Shapira commented on KAFKA-3346: - actually, I like connectionMode better. But I still think that

[jira] [Commented] (KAFKA-3346) Rename "Mode" to "SslMode"

[ https://issues.apache.org/jira/browse/KAFKA-3346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15184136#comment-15184136 ] Gwen Shapira commented on KAFKA-3346: - Maybe we can change Mode to loginType and loginType to

[jira] [Created] (KAFKA-3346) Rename "Mode" to "SslMode"

Gwen Shapira created KAFKA-3346: --- Summary: Rename "Mode" to "SslMode" Key: KAFKA-3346 URL: https://issues.apache.org/jira/browse/KAFKA-3346 Project: Kafka Issue Type: Bug Reporter:

[jira] [Updated] (KAFKA-3341) Improve error handling on invalid requests

[ https://issues.apache.org/jira/browse/KAFKA-3341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3341: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Resolved] (KAFKA-3339) org.apache.kafka.clients.consumer.KafkaConsumer javadoc for seekToBeginning, seekToEnd incomplete

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

[jira] [Commented] (KAFKA-3233) Per topic consumer metrics missing in new consumer's metrics reporter

[ https://issues.apache.org/jira/browse/KAFKA-3233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15183502#comment-15183502 ] Gwen Shapira commented on KAFKA-3233: - Since the change was merged into trunk, it will be included in

[jira] [Updated] (KAFKA-3281) Improve message of stop scripts when no processes are running

[ https://issues.apache.org/jira/browse/KAFKA-3281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3281: Resolution: Fixed Fix Version/s: 0.10.0.0 Status: Resolved (was: Patch Available)

[jira] [Updated] (KAFKA-3187) Make kafka-acls.sh help messages more generic.

[ https://issues.apache.org/jira/browse/KAFKA-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3187: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-3286) Add plugin to quickly check for outdated dependencies

[ https://issues.apache.org/jira/browse/KAFKA-3286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3286: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Commented] (KAFKA-2636) Producer connectivity obscured connection failure logging

[ https://issues.apache.org/jira/browse/KAFKA-2636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178642#comment-15178642 ] Gwen Shapira commented on KAFKA-2636: - async send doesn't throw an exception (because there's nowhere

[jira] [Resolved] (KAFKA-3325) Out of date instructions in quickstart guide

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

[jira] [Updated] (KAFKA-3314) Add CDDL license to LICENSE and NOTICE file

[ https://issues.apache.org/jira/browse/KAFKA-3314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3314: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-3304) KIP-35 - Retrieving protocol version

[ https://issues.apache.org/jira/browse/KAFKA-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3304: Reviewer: Magnus Edenhill > KIP-35 - Retrieving protocol version >

[jira] [Updated] (KAFKA-3284) Consider removing beta label in security documentation

[ https://issues.apache.org/jira/browse/KAFKA-3284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3284: Reviewer: Gwen Shapira > Consider removing beta label in security documentation >

[jira] [Updated] (KAFKA-2982) Mark the old Scala producer and related classes as deprecated

[ https://issues.apache.org/jira/browse/KAFKA-2982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2982: Assignee: Grant Henke Reviewer: Gwen Shapira > Mark the old Scala producer and related classes

[jira] [Updated] (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:all-tabpanel ] Gwen Shapira updated KAFKA-3006: Assignee: Pierre-Yves Ritschard Reviewer: Jason Gustafson > Make collection default container

[jira] [Updated] (KAFKA-3190) KafkaProducer should not invoke callback in send()

[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3190: Reviewer: Guozhang Wang > KafkaProducer should not invoke callback in send() >

[jira] [Updated] (KAFKA-3283) Consider marking the new consumer as production-ready

[ https://issues.apache.org/jira/browse/KAFKA-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3283: Assignee: Jason Gustafson Reviewer: Gwen Shapira > Consider marking the new consumer as

[jira] [Updated] (KAFKA-1215) Rack-Aware replica assignment option

[ https://issues.apache.org/jira/browse/KAFKA-1215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1215: Reviewer: Jun Rao > Rack-Aware replica assignment option > > >

[jira] [Updated] (KAFKA-2658) Implement SASL/PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2658: Reviewer: Jun Rao > Implement SASL/PLAIN > > > Key: KAFKA-2658

[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 ] Gwen Shapira updated KAFKA-3201: Reviewer: Ewen Cheslack-Postava > Add system test for KIP-31 and KIP-32 - Upgrade Test >

[jira] [Updated] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3202: Assignee: Anna Povzner Reviewer: Ewen Cheslack-Postava > Add system test for KIP-31 and KIP-32

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

[ https://issues.apache.org/jira/browse/KAFKA-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3188: Reviewer: Ewen Cheslack-Postava > Add system test for KIP-31 and KIP-32 - Compatibility Test >

[jira] [Updated] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

[ https://issues.apache.org/jira/browse/KAFKA-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3197: Reviewer: Jun Rao > Producer can send message out of order even when in flight request is set to >

[jira] [Updated] (KAFKA-3303) Pass partial record metadata to Interceptor onAcknowledgement in case of errors

[ https://issues.apache.org/jira/browse/KAFKA-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3303: Reviewer: Jun Rao > Pass partial record metadata to Interceptor onAcknowledgement in case of >

[jira] [Updated] (KAFKA-3314) Add CDDL license to LICENSE and NOTICE file

[ https://issues.apache.org/jira/browse/KAFKA-3314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3314: Reviewer: Gwen Shapira > Add CDDL license to LICENSE and NOTICE file >

[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 ] Gwen Shapira updated KAFKA-2370: Reviewer: Gwen Shapira > Add pause/unpause connector support > ---

[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 ] Gwen Shapira updated KAFKA-3316: Reviewer: Gwen Shapira > Add Connect REST API to list available connector classes >

[jira] [Updated] (KAFKA-2784) Mirror maker should swallow exceptions during shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-2784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2784: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

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

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

[jira] [Created] (KAFKA-3321) KafkaConfigStorage should never encounter commit without config data

Gwen Shapira created KAFKA-3321: --- Summary: KafkaConfigStorage should never encounter commit without config data Key: KAFKA-3321 URL: https://issues.apache.org/jira/browse/KAFKA-3321 Project: Kafka

[jira] [Updated] (KAFKA-3310) fetch requests can trigger repeated NPE when quota is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3310: Priority: Blocker (was: Major) > fetch requests can trigger repeated NPE when quota is enabled >

[jira] [Resolved] (KAFKA-2923) Improve 0.9.0 Upgrade Documents

[ https://issues.apache.org/jira/browse/KAFKA-2923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2923. - Resolution: Fixed > Improve 0.9.0 Upgrade Documents > > >

[jira] [Updated] (KAFKA-3314) Add CDDL license to LICENSE and NOTICE file

[ https://issues.apache.org/jira/browse/KAFKA-3314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3314: Priority: Blocker (was: Major) > Add CDDL license to LICENSE and NOTICE file >

[jira] [Commented] (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:comment-tabpanel=15174991#comment-15174991 ] Gwen Shapira commented on KAFKA-2944: - Created PR https://github.com/apache/kafka/pull/993 for partial

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

Gwen Shapira created KAFKA-3299: --- Summary: KafkaConnect: DistributedHerder shouldn't wait forever to read configs after rebalance Key: KAFKA-3299 URL: https://issues.apache.org/jira/browse/KAFKA-3299

[jira] [Resolved] (KAFKA-3280) KafkaConsumer Javadoc contains misleading description of heartbeat behavior and correct use

[ https://issues.apache.org/jira/browse/KAFKA-3280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3280. - Resolution: Fixed Issue resolved by pull request 968 [https://github.com/apache/kafka/pull/968]

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168130#comment-15168130 ] Gwen Shapira commented on KAFKA-1696: - OK, sounds good. Thanks. It does make this issue depend on

[jira] [Commented] (KAFKA-3284) Consider removing beta label in security documentation

[ https://issues.apache.org/jira/browse/KAFKA-3284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167958#comment-15167958 ] Gwen Shapira commented on KAFKA-3284: - IMO: At least one large deployment saying they are using the

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167942#comment-15167942 ] Gwen Shapira commented on KAFKA-1696: - One thing I can't find in the KIP: * Will we support

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167939#comment-15167939 ] Gwen Shapira commented on KAFKA-1696: - I don't have specific opinions on the KIP yet, I have not read

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167913#comment-15167913 ] Gwen Shapira commented on KAFKA-1696: - Just to clarify - the move away from ZK is for clients, not for

[jira] [Commented] (KAFKA-3284) Consider removing beta label in security documentation

[ https://issues.apache.org/jira/browse/KAFKA-3284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167650#comment-15167650 ] Gwen Shapira commented on KAFKA-3284: - Just a doc change, right? > Consider removing beta label in

[jira] [Commented] (KAFKA-3274) Document command line tools

[ https://issues.apache.org/jira/browse/KAFKA-3274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15160150#comment-15160150 ] Gwen Shapira commented on KAFKA-3274: - Docs collocated with source. Since they are properly versioned.

[jira] [Created] (KAFKA-3274) Document command line tools

Gwen Shapira created KAFKA-3274: --- Summary: Document command line tools Key: KAFKA-3274 URL: https://issues.apache.org/jira/browse/KAFKA-3274 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-3272) Add debugging options to kafka-run-class.sh so we can easily run remote debugging

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

[jira] [Resolved] (KAFKA-3242) "Add Partition" log message doesn't actually indicate adding a partition

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

[jira] [Resolved] (KAFKA-3235) Unclosed stream in AppInfoParser static block

[ https://issues.apache.org/jira/browse/KAFKA-3235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3235. - Resolution: Fixed Issue resolved by pull request 914 [https://github.com/apache/kafka/pull/914]

[jira] [Commented] (KAFKA-3247) kafka-topic tool can use an option to see just "unbalanced partitions"

[ https://issues.apache.org/jira/browse/KAFKA-3247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15154743#comment-15154743 ] Gwen Shapira commented on KAFKA-3247: - Go for it, [~singhashish] > kafka-topic tool can use an option

[jira] [Commented] (KAFKA-3250) release tarball is unnecessarily large due to duplicate libraries

[ https://issues.apache.org/jira/browse/KAFKA-3250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15153395#comment-15153395 ] Gwen Shapira commented on KAFKA-3250: - It does not. {code} Chens-MacBook-Pro:distributions gwen$ ls

[jira] [Created] (KAFKA-3250) release tarball is unnecessarily large due to duplicate libraries

Gwen Shapira created KAFKA-3250: --- Summary: release tarball is unnecessarily large due to duplicate libraries Key: KAFKA-3250 URL: https://issues.apache.org/jira/browse/KAFKA-3250 Project: Kafka

[jira] [Created] (KAFKA-3247) kafka-topic tool can use an option to see just "unbalanced partitions"

Gwen Shapira created KAFKA-3247: --- Summary: kafka-topic tool can use an option to see just "unbalanced partitions" Key: KAFKA-3247 URL: https://issues.apache.org/jira/browse/KAFKA-3247 Project: Kafka

[jira] [Created] (KAFKA-3244) TopipicCommand doesn't allow to add partitions with specific assignment

Gwen Shapira created KAFKA-3244: --- Summary: TopipicCommand doesn't allow to add partitions with specific assignment Key: KAFKA-3244 URL: https://issues.apache.org/jira/browse/KAFKA-3244 Project: Kafka

<    1   2   3   4   5   6   7   8   9   10   >