[jira] [Commented] (KAFKA-2334) Prevent HW from going back during leader failover

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030772#comment-16030772 ] Ismael Juma commented on KAFKA-2334: Is this still an issue? > Prevent HW from going back during

[jira] [Updated] (KAFKA-2334) Prevent HW from going back during leader failover

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2334: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Prevent HW from going back during

[jira] [Commented] (KAFKA-2651) Remove deprecated config alteration from TopicCommand in 0.9.1.0

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030768#comment-16030768 ] Ismael Juma commented on KAFKA-2651: [~omkreddy], yes, I'm aware that it has been deprecated, but no

[jira] [Updated] (KAFKA-2651) Remove deprecated config alteration from TopicCommand in 0.9.1.0

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2651: --- Fix Version/s: (was: 0.11.0.0) 0.12.0.0 > Remove deprecated config alteration

[jira] [Updated] (KAFKA-2947) AlterTopic - protocol and server side implementation

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2947: --- Fix Version/s: (was: 0.11.0.0) > AlterTopic - protocol and server side implementation >

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

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2939: --- Fix Version/s: (was: 0.11.0.0) > Make AbstractConfig.logUnused() tunable for clients >

[jira] [Updated] (KAFKA-3866) KerberosLogin refresh time bug and other improvements

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3866: --- Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > KerberosLogin refresh time bug and

[jira] [Updated] (KAFKA-3986) completedReceives can contain closed channels

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3986: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > completedReceives can contain closed

[jira] [Commented] (KAFKA-4665) Inconsistent handling of non-existing topics in offset fetch handling

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030736#comment-16030736 ] Ismael Juma commented on KAFKA-4665: [~hachikuji], is this still planned for 0.11.0.0? > Inconsistent

[jira] [Updated] (KAFKA-3689) Exception when attempting to decrease connection count for address with no connections

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3689: --- Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > Exception when attempting to

[jira] [Updated] (KAFKA-4637) Update system test(s) to use multiple listeners for the same security protocol

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4637: --- Labels: newbie (was: ) > Update system test(s) to use multiple listeners for the same security

[jira] [Updated] (KAFKA-4637) Update system test(s) to use multiple listeners for the same security protocol

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4637: --- Fix Version/s: (was: 0.11.0.0) > Update system test(s) to use multiple listeners for the same

[jira] [Updated] (KAFKA-4668) Mirrormaker should default to auto.offset.reset=earliest

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4668: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Mirrormaker should default to

[jira] [Commented] (KAFKA-4668) Mirrormaker should default to auto.offset.reset=earliest

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030735#comment-16030735 ] Ismael Juma commented on KAFKA-4668: This probably needs a simple KIP. Also cc [~becket_qin] for

[jira] [Commented] (KAFKA-4785) Records from internal repartitioning topics should always use RecordMetadataTimestampExtractor

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030732#comment-16030732 ] Ismael Juma commented on KAFKA-4785: Is this still planned for 0.11.0.0? > Records from internal

[jira] [Updated] (KAFKA-4686) Null Message payload is shutting down broker

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4686: --- Priority: Critical (was: Major) > Null Message payload is shutting down broker >

[jira] [Updated] (KAFKA-4686) Null Message payload is shutting down broker

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4686: --- Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > Null Message payload is shutting

[jira] [Updated] (KAFKA-4808) send of null key to a compacted topic should throw error back to user

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4808: --- Status: Patch Available (was: Open) > send of null key to a compacted topic should throw error back

[jira] [Updated] (KAFKA-4808) send of null key to a compacted topic should throw error back to user

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4808: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > send of null key to a compacted

[jira] [Updated] (KAFKA-5031) Additional validation in validateMessagesAndAssignOffsets

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5031: --- Status: Patch Available (was: Open) > Additional validation in validateMessagesAndAssignOffsets >

[jira] [Updated] (KAFKA-5051) Avoid DNS reverse lookup in security-critical TLS code path

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5051: --- Status: Patch Available (was: Open) > Avoid DNS reverse lookup in security-critical TLS code path >

[jira] [Resolved] (KAFKA-5059) Implement Transactional Coordinator

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5059. Resolution: Fixed Marking this as resolved since all, but one task have been completed and the

[jira] [Updated] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5212: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Consumer ListOffsets request can

[jira] [Updated] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1482: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Transient test failures for >

[jira] [Updated] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4972: --- Fix Version/s: (was: 0.12.0.0) (was: 0.11.0.0) 0.11.0.1

[jira] [Updated] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4669: --- Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > KafkaProducer.flush hangs when

[jira] [Commented] (KAFKA-4595) Controller send thread can't stop when broker change listener event trigger for dead brokers

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030705#comment-16030705 ] Ismael Juma commented on KAFKA-4595: [~junrao], is this fixed given that deletion no longer happens in

[jira] [Updated] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3955: --- Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > Kafka log recovery doesn't truncate

[jira] [Updated] (KAFKA-1694) KIP-4: Command line and centralized operations

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1694: --- Fix Version/s: (was: 0.11.0.0) > KIP-4: Command line and centralized operations >

[jira] [Commented] (KAFKA-5321) MemoryRecords.filterTo can return corrupt data if output buffer is not large enough

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030703#comment-16030703 ] Ismael Juma commented on KAFKA-5321: [~hachikuji], this was fixed as part of KAFKA-5316, right? >

[jira] [Updated] (KAFKA-4693) Consumer subscription change during rebalance causes exception

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4693: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Consumer subscription change during

[jira] [Updated] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4950: --- Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > ConcurrentModificationException when

[jira] [Commented] (KAFKA-5218) New Short serializer, deserializer, serde

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030701#comment-16030701 ] Ismael Juma commented on KAFKA-5218: Is this still planned for 0.11.0.0? > New Short serializer,

[jira] [Updated] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2875: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Class path contains multiple SLF4J

[jira] [Updated] (KAFKA-3733) Avoid long command lines by setting CLASSPATH in environment

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3733: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Avoid long command lines by setting

[jira] [Commented] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030700#comment-16030700 ] Ismael Juma commented on KAFKA-4064: Is this still planned for 0.11.0.0? > Add support for infinite

[jira] [Updated] (KAFKA-1548) Refactor the "replica_id" in requests

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1548: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Refactor the "replica_id" in

[jira] [Updated] (KAFKA-1899) Update code coverage report generation once gradle-scoverage starts publishing scoverage report

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1899: --- Fix Version/s: (was: 0.11.0.0) > Update code coverage report generation once gradle-scoverage

[jira] [Updated] (KAFKA-1900) Add documentation on usage of code coverage in the project and how it works

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1900: --- Fix Version/s: (was: 0.11.0.0) > Add documentation on usage of code coverage in the project and

[jira] [Updated] (KAFKA-2394) Use RollingFileAppender by default in log4j.properties

2017-05-31 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2394: --- Fix Version/s: (was: 0.11.0.0) 0.12.0.0 > Use RollingFileAppender by default

[jira] [Resolved] (KAFKA-5324) AdminClient: add close with timeout, fix some timeout bugs

2017-05-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5324. Resolution: Fixed Fix Version/s: 0.11.0.0 > AdminClient: add close with timeout, fix some

[jira] [Assigned] (KAFKA-5293) Do not apply exponential backoff if users have overridden reconnect.backoff.ms

2017-05-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-5293: -- Assignee: Colin P. McCabe (was: Ismael Juma) > Do not apply exponential backoff if users have

[jira] [Updated] (KAFKA-5344) Change message.timestamp.difference.max.ms back to Long.MaxValue

2017-05-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5344: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Resolved] (KAFKA-4340) Change the default value of log.message.timestamp.difference.max.ms to the same as log.retention.ms

2017-05-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4340. Resolution: Won't Fix Compacted topics means that we would also need KAFKA-4907 to avoid rejecting

[jira] [Updated] (KAFKA-4340) Change the default value of log.message.timestamp.difference.max.ms to the same as log.retention.ms

2017-05-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4340: --- Fix Version/s: (was: 0.11.0.0) > Change the default value of

[jira] [Resolved] (KAFKA-4907) compacted topic shouldn't reject messages with old timestamp

2017-05-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4907. Resolution: Won't Fix We decided to change the default of `message.timestamp.difference.max.ms`

[jira] [Updated] (KAFKA-5219) Move transaction expiration logic and scheduling to the Transaction Manager

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5219: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Move transaction expiration logic

[jira] [Updated] (KAFKA-5333) Remove Broker ACL resource type

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5333: --- Priority: Critical (was: Major) > Remove Broker ACL resource type > ---

[jira] [Updated] (KAFKA-5333) Remove Broker ACL resource type

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5333: --- Status: Patch Available (was: Open) > Remove Broker ACL resource type >

[jira] [Updated] (KAFKA-5333) Remove Broker ACL resource type

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5333: --- Fix Version/s: 0.11.0.0 > Remove Broker ACL resource type > --- > >

[jira] [Created] (KAFKA-5333) Remove Broker ACL resource type

2017-05-26 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-5333: -- Summary: Remove Broker ACL resource type Key: KAFKA-5333 URL: https://issues.apache.org/jira/browse/KAFKA-5333 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-4459) rat license check not running in Jenkins

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4459: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > rat license check not running in

[jira] [Updated] (KAFKA-4345) Run ducktape test for each pull request

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4345: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Run ducktape test for each pull

[jira] [Updated] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer)

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3297: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > More optimally balanced partition

[jira] [Updated] (KAFKA-3135) Unexpected delay before fetch response transmission

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3135: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Unexpected delay before fetch

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

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3247: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > kafka-topic tool can use an option

[jira] [Updated] (KAFKA-3331) Refactor TopicCommand to make it testable and add unit tests

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3331: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Refactor TopicCommand to make it

[jira] [Updated] (KAFKA-4440) Make producer RecordMetadata non-final

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4440: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Make producer RecordMetadata

[jira] [Updated] (KAFKA-2983) Remove old Scala clients and all related code, tests, and tools.

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2983: --- Fix Version/s: (was: 0.11.0.0) 0.12.0.0 > Remove old Scala clients and all

[jira] [Updated] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition.

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3177: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Kafka consumer can hang when

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

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3190: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > KafkaProducer should not invoke

[jira] [Updated] (KAFKA-3300) Calculate the initial/max size of offset index files and reduce the memory footprint for memory mapped index files.

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3300: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Calculate the initial/max size of

[jira] [Updated] (KAFKA-4602) KIP-72 Allow putting a bound on memory consumed by Incoming requests

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4602: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > KIP-72 Allow putting a bound on

[jira] [Updated] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1342: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Slow controlled shutdowns can result

[jira] [Updated] (KAFKA-3186) KIP-50: Move Authorizer and related classes to separate package.

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3186: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > KIP-50: Move Authorizer and related

[jira] [Updated] (KAFKA-1326) New consumer checklist

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1326: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > New consumer checklist >

[jira] [Updated] (KAFKA-4922) Fix several FindBugs warnings in Clients and Connect

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4922: --- Resolution: Fixed Status: Resolved (was: Patch Available) I believe these were fixed via a

[jira] [Resolved] (KAFKA-4973) Transient failure of AdminClientTest.testDeleteRecordsWithException

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4973. Resolution: Fixed > Transient failure of AdminClientTest.testDeleteRecordsWithException >

[jira] [Updated] (KAFKA-3436) Speed up controlled shutdown.

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3436: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Speed up controlled shutdown. >

[jira] [Updated] (KAFKA-5022) Improve CRC tests so that we verify which fields are included in the CRC

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5022: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve CRC tests so that we verify

[jira] [Updated] (KAFKA-5023) Remove cyclic dependency between record and protocol packages

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5023: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Remove cyclic dependency between

[jira] [Updated] (KAFKA-5011) Replica fetchers may need to down-convert messages during a selective message format upgrade

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5011: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Replica fetchers may need to

[jira] [Updated] (KAFKA-4862) Kafka client connect to a shutdown node will block for a long time

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4862: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Kafka client connect to a shutdown

[jira] [Commented] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16026227#comment-16026227 ] Ismael Juma commented on KAFKA-3955: Unless we get a PR for this very soon, it won't happen for

[jira] [Commented] (KAFKA-5116) Controller updates to ISR holds the controller lock for a very long time

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16026224#comment-16026224 ] Ismael Juma commented on KAFKA-5116: Moving to the next release given that the code freeze is next

[jira] [Updated] (KAFKA-4501) Support Java 9

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4501: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Support Java 9 > -- > >

[jira] [Updated] (KAFKA-5092) KIP 141 - ProducerRecord Interface Improvements

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5092: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > KIP 141 - ProducerRecord Interface

[jira] [Updated] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3042: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > updateIsr should stop after failed

[jira] [Updated] (KAFKA-4423) Drop support for Java 7

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4423: --- Fix Version/s: (was: 0.11.0.0) 0.12.0.0 > Drop support for Java 7 >

[jira] [Updated] (KAFKA-5116) Controller updates to ISR holds the controller lock for a very long time

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5116: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Controller updates to ISR holds the

[jira] [Updated] (KAFKA-1894) Avoid long or infinite blocking in the consumer

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1894: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Avoid long or infinite blocking in

[jira] [Resolved] (KAFKA-5108) Add support for reading PID snapshot files to DumpLogSegments

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5108. Resolution: Fixed > Add support for reading PID snapshot files to DumpLogSegments >

[jira] [Resolved] (KAFKA-5133) Changing "connection refused" message from logging level "debug" into "warn"

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5133. Resolution: Duplicate This was resolved via a different ticket so that we get warnings if the

[jira] [Comment Edited] (KAFKA-5133) Changing "connection refused" message from logging level "debug" into "warn"

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16026218#comment-16026218 ] Ismael Juma edited comment on KAFKA-5133 at 5/26/17 12:36 PM: -- This was

[jira] [Updated] (KAFKA-5133) Changing "connection refused" message from logging level "debug" into "warn"

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5133: --- Fix Version/s: (was: 0.11.0.0) > Changing "connection refused" message from logging level "debug"

[jira] [Resolved] (KAFKA-4421) Update release process so that Scala 2.12 artifacts are published

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4421. Resolution: Fixed Assignee: Ewen Cheslack-Postava > Update release process so that Scala 2.12

[jira] [Updated] (KAFKA-4764) Improve diagnostics for SASL authentication failures

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4764: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve diagnostics for SASL

[jira] [Updated] (KAFKA-5185) Adding the RecordMetadata that is returned by the producer to the commitRecord method for SourceTask

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5185: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Adding the RecordMetadata that is

[jira] [Updated] (KAFKA-5234) GetOffsetShell: retrieve offsets for multiple topics with single request

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5234: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > GetOffsetShell: retrieve offsets for

[jira] [Updated] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool.

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3554: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Generate actual data with specific

[jira] [Updated] (KAFKA-5293) Do not apply exponential backoff if users have overridden reconnect.backoff.ms

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5293: --- Reporter: Ismael Juma (was: Colin P. McCabe) > Do not apply exponential backoff if users have

[jira] [Updated] (KAFKA-5017) Consider making baseOffset the first offset in message format v2

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5017: --- Fix Version/s: (was: 0.11.0.0) > Consider making baseOffset the first offset in message format v2

[jira] [Updated] (KAFKA-5025) FetchRequestTest should use batches with more than one message

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5025: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > FetchRequestTest should use batches

[jira] [Updated] (KAFKA-5030) Suggested clean-ups from message format V2 review

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5030: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Suggested clean-ups from message

[jira] [Updated] (KAFKA-5235) GetOffsetShell: retrieve offsets for all given topics and partitions with single request to the broker

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5235: --- Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > GetOffsetShell: retrieve offsets for

[jira] [Resolved] (KAFKA-5250) handleFetchRequest should do down conversion after throttling

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5250. Resolution: Fixed > handleFetchRequest should do down conversion after throttling >

[jira] [Commented] (KAFKA-5032) Think through implications of max.message.size affecting record batches in message format V2

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16026211#comment-16026211 ] Ismael Juma commented on KAFKA-5032: [~apurva], docs sound good. Maybe we should consider changing the

[jira] [Commented] (KAFKA-5328) consider switching json parser from scala to jackson

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16026052#comment-16026052 ] Ismael Juma commented on KAFKA-5328: Duplicate of KAFKA-1595, which had a PR. If there's interest in

[jira] [Commented] (KAFKA-5332) When resize the index file, maybe caused the content disappear

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16026050#comment-16026050 ] Ismael Juma commented on KAFKA-5332: cc [~junrao] > When resize the index file, maybe caused the

[jira] [Commented] (KAFKA-5329) Replica list in the metadata cache on the broker may have different order from zookeeper

2017-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16026049#comment-16026049 ] Ismael Juma commented on KAFKA-5329: Are you sure that this is an issue [~becket_qin]? We rely on

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