Build failed in Jenkins: kafka-0.10.1-jdk7 #17

See Changes: [jason] MINOR: Remove no longer required --new-consumer switch in docs [wangguoz] HOTFIX: fix npe in StreamsMetadataState when onChange has not been [wangguoz] MINOR: fixes a few error logging formats [wangguoz] MINOR:

Re: [DISCUSS] KIP-83 - Allow multiple SASL PLAIN authenticated Java clients in a single JVM process

Edorado, Thanks for the KIP. As pointed out in the JIRA can you make sure this is not just a specific change for SASL plain but make changes in general to LoginManager such that its not a singleton. Thanks, Harsha On Tue, Sep 27, 2016 at 10:15 AM Edoardo Comar

Build failed in Jenkins: kafka-trunk-jdk7 #1576

See Changes: [jason] MINOR: Remove no longer required --new-consumer switch in docs [wangguoz] HOTFIX: fix npe in StreamsMetadataState when onChange has not been [wangguoz] MINOR: fixes a few error logging formats [wangguoz] MINOR:

[GitHub] kafka pull request #1924: Merge pull request #1 from apache/trunk

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

[jira] [Updated] (KAFKA-3965) Mirror maker sync send fails will lose messages

[ https://issues.apache.org/jira/browse/KAFKA-3965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3965: --- Priority: Critical (was: Major) > Mirror maker sync send fails will lose messages >

[jira] [Updated] (KAFKA-4019) LogCleaner should grow read/write buffer to max message size for the topic

[ https://issues.apache.org/jira/browse/KAFKA-4019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4019: --- Priority: Critical (was: Major) > LogCleaner should grow read/write buffer to max message size for

[jira] [Updated] (KAFKA-3374) Failure in security rolling upgrade phase 2 system test

[ https://issues.apache.org/jira/browse/KAFKA-3374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3374: --- Priority: Major (was: Critical) > Failure in security rolling upgrade phase 2 system test >

[jira] [Updated] (KAFKA-2692) Add ducktape tests for SASL/Kerberos

[ https://issues.apache.org/jira/browse/KAFKA-2692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2692: --- Assignee: (was: Ismael Juma) > Add ducktape tests for SASL/Kerberos >

[jira] [Updated] (KAFKA-2609) SSL renegotiation code paths need more tests

[ https://issues.apache.org/jira/browse/KAFKA-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2609: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > SSL renegotiation code paths need

[jira] [Updated] (KAFKA-2692) Add ducktape tests for SASL/Kerberos

[ https://issues.apache.org/jira/browse/KAFKA-2692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2692: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add ducktape tests for SASL/Kerberos

[jira] [Updated] (KAFKA-3428) Remove metadata sync bottleneck from mirrormaker's producer

[ https://issues.apache.org/jira/browse/KAFKA-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3428: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Remove metadata sync bottleneck from

[jira] [Updated] (KAFKA-2952) Add ducktape test for secure->unsecure ZK migration

[ https://issues.apache.org/jira/browse/KAFKA-2952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2952: --- Fix Version/s: (was: 0.10.1.0) > Add ducktape test for secure->unsecure ZK migration >

[jira] [Commented] (KAFKA-1573) Transient test failures on LogTest.testCorruptLog

[ https://issues.apache.org/jira/browse/KAFKA-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528258#comment-15528258 ] Vahid Hashemian commented on KAFKA-1573: I ran the {{LogTest}} unit tests 1000 times on my Ubuntu

[GitHub] kafka pull request #1924: Merge pull request #1 from apache/trunk

GitHub user wangzzu opened a pull request: https://github.com/apache/kafka/pull/1924 Merge pull request #1 from apache/trunk update from origin You can merge this pull request into a Git repository by running: $ git pull https://github.com/wangzzu/kafka trunk Alternatively

[GitHub] kafka pull request #1923: Merge pull request #1 from apache/trunk

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

[jira] [Created] (KAFKA-4226) Surprising NoOffsetForPartitionException for paused partition with no reset policy

Jason Gustafson created KAFKA-4226: -- Summary: Surprising NoOffsetForPartitionException for paused partition with no reset policy Key: KAFKA-4226 URL: https://issues.apache.org/jira/browse/KAFKA-4226

[GitHub] kafka pull request #1923: Merge pull request #1 from apache/trunk

GitHub user wangzzu opened a pull request: https://github.com/apache/kafka/pull/1923 Merge pull request #1 from apache/trunk update from origin You can merge this pull request into a Git repository by running: $ git pull https://github.com/wangzzu/kafka trunk Alternatively

Build failed in Jenkins: kafka-trunk-jdk8 #919

See Changes: [ismael] MINOR: Make new consumer default for Mirror Maker [jason] MINOR: Remove no longer required --new-consumer switch in docs -- [...truncated 13726 lines...]

[GitHub] kafka pull request #1922: HOTFIX: remove git conflicts

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

Re: [UPDATE] 0.10.1 Release Progress

Thanks Jason! On Tue, Sep 27, 2016 at 5:38 PM, Ismael Juma wrote: > Thanks for the update Jason. :) > > Ismael > > On Wed, Sep 28, 2016 at 1:28 AM, Jason Gustafson > wrote: > > > Hi All, > > > > Pardon all the JIRA noise, but I've been busy reducing the

Build failed in Jenkins: kafka-0.10.1-jdk7 #16

See Changes: [ismael] MINOR: Make new consumer default for Mirror Maker -- [...truncated 13687 lines...] org.apache.kafka.streams.StreamsConfigTest > shouldSupportPrefixedConsumerConfigs

[GitHub] kafka pull request #1922: HOTFIX: remove git conflicts

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/1922 HOTFIX: remove git conflicts You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KHotfix-streams-html Alternatively you

[GitHub] kafka pull request #1916: MINOR: add test to make sure ProcessorStateManager...

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

Re: [UPDATE] 0.10.1 Release Progress

Thanks for the update Jason. :) Ismael On Wed, Sep 28, 2016 at 1:28 AM, Jason Gustafson wrote: > Hi All, > > Pardon all the JIRA noise, but I've been busy reducing the scope to match > the available time since we're now 6 days from the code freeze. I've pruned > the list to

[GitHub] kafka pull request #1919: MINOR: fixes a few error logging formats

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

[GitHub] kafka pull request #1920: HOTFIX: fix npe in StreamsMetadataState when onCha...

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

Re: [UPDATE] 0.10.1 Release Progress

Hi All, Pardon all the JIRA noise, but I've been busy reducing the scope to match the available time since we're now 6 days from the code freeze. I've pruned the list to about 30 tickets, some of which probably won't get in: https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+0.10.1.

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527841#comment-15527841 ] Elias Levy commented on KAFKA-4212: --- Looks like using {{WindowStore}} is not quite so simple, as you

[GitHub] kafka pull request #1905: MINOR: Remove no longer required --new-consumer sw...

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

Build failed in Jenkins: kafka-trunk-jdk8 #918

See Changes: [ismael] KAFKA-4177; Remove ThrottledReplicationRateLimit from Server Config -- [...truncated 12267 lines...] :core:copyDependantLibs :core:jar :examples:compileJavawarning:

[jira] [Updated] (KAFKA-4178) Replication Throttling: Consolidate Rate Classes

[ https://issues.apache.org/jira/browse/KAFKA-4178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4178: --- Fix Version/s: 0.10.1.0 > Replication Throttling: Consolidate Rate Classes >

[jira] [Updated] (KAFKA-4213) Add system tests for replication throttling (KIP-73)

[ https://issues.apache.org/jira/browse/KAFKA-4213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4213: --- Fix Version/s: 0.10.1.0 > Add system tests for replication throttling (KIP-73) >

[jira] [Updated] (KAFKA-2806) Allow Kafka System Tests under different JDK versions

[ https://issues.apache.org/jira/browse/KAFKA-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2806: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Allow Kafka System Tests

[jira] [Updated] (KAFKA-3704) Improve mechanism for compression stream block size selection in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3704: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Improve mechanism for

[jira] [Updated] (KAFKA-3473) Add controller channel manager request queue time metric.

[ https://issues.apache.org/jira/browse/KAFKA-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3473: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add controller channel

[jira] [Updated] (KAFKA-3097) Acls for PrincipalType User are case sensitive

[ https://issues.apache.org/jira/browse/KAFKA-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3097: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Acls for PrincipalType User

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

[ https://issues.apache.org/jira/browse/KAFKA-3866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3866: --- Fix Version/s: (was: 0.10.1.0) 0.10.1.1 > KerberosLogin refresh time

[jira] [Updated] (KAFKA-1985) Document on possible error codes for each response type

[ https://issues.apache.org/jira/browse/KAFKA-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1985: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Document on possible error

[jira] [Updated] (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:all-tabpanel ] Jason Gustafson updated KAFKA-3247: --- Issue Type: Improvement (was: Bug) > kafka-topic tool can use an option to see just

[jira] [Updated] (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:all-tabpanel ] Jason Gustafson updated KAFKA-3247: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > kafka-topic tool can use an

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

[ https://issues.apache.org/jira/browse/KAFKA-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3300: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Calculate the initial/max

[jira] [Updated] (KAFKA-3145) CPU Usage Spike to 100% when network connection is to error port

[ https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3145: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > CPU Usage Spike to 100% when

[jira] [Updated] (KAFKA-1800) KafkaException was not recorded at the per-topic metrics

[ https://issues.apache.org/jira/browse/KAFKA-1800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1800: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > KafkaException was not

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

[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1342: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Slow controlled shutdowns

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3734: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Exceptions in

[jira] [Updated] (KAFKA-1352) Reduce logging on the server

[ https://issues.apache.org/jira/browse/KAFKA-1352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1352: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Reduce logging on the server

Build failed in Jenkins: kafka-0.10.1-jdk7 #15

See Changes: [ismael] KAFKA-4177; Remove ThrottledReplicationRateLimit from Server Config -- [...truncated 13682 lines...] org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >

[jira] [Commented] (KAFKA-3697) Clean-up website documentation when it comes to clients

[ https://issues.apache.org/jira/browse/KAFKA-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527729#comment-15527729 ] ASF GitHub Bot commented on KAFKA-3697: --- GitHub user vahidhashemian opened a pull request:

[jira] [Updated] (KAFKA-1354) Failed to load class "org.slf4j.impl.StaticLoggerBinder"

[ https://issues.apache.org/jira/browse/KAFKA-1354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1354: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Failed to load class

[GitHub] kafka pull request #1921: KAFKA-3697: Refer to "new" consumer/producer as "J...

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/1921 KAFKA-3697: Refer to "new" consumer/producer as "Java" consumer/producer in the documentation This is to imply that the Java consumer/producer are the recommended consumer/producer now.

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

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2939: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Make

[jira] [Updated] (KAFKA-3829) Warn that kafka-connect group.id must not conflict with connector names

[ https://issues.apache.org/jira/browse/KAFKA-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3829: --- Priority: Major (was: Critical) > Warn that kafka-connect group.id must not conflict with

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

[ https://issues.apache.org/jira/browse/KAFKA-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3689: --- Fix Version/s: (was: 0.10.1.0) 0.10.1.1 > Exception when attempting to

[jira] [Updated] (KAFKA-3252) compression type for a topic should be used during log compaction

[ https://issues.apache.org/jira/browse/KAFKA-3252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3252: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > compression type for a topic

[jira] [Updated] (KAFKA-1590) Binarize trace level request logging along with debug level text logging

[ https://issues.apache.org/jira/browse/KAFKA-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1590: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Binarize trace level request

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

[ https://issues.apache.org/jira/browse/KAFKA-3733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3733: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Avoid long command lines by

[jira] [Updated] (KAFKA-1610) Local modifications to collections generated from mapValues will be lost

[ https://issues.apache.org/jira/browse/KAFKA-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1610: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Local modifications to

[jira] [Updated] (KAFKA-3365) Add a documentation field for types and update doc generation

[ https://issues.apache.org/jira/browse/KAFKA-3365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3365: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add a documentation field

[jira] [Updated] (KAFKA-451) follower replica may need to backoff the fetching if leader is not ready yet

[ https://issues.apache.org/jira/browse/KAFKA-451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-451: -- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > follower replica may need to

[jira] [Updated] (KAFKA-3363) Add a documentation field for schemas and update doc generation

[ https://issues.apache.org/jira/browse/KAFKA-3363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3363: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add a documentation field

[jira] [Updated] (KAFKA-3362) Update protocol schema and field doc strings

[ https://issues.apache.org/jira/browse/KAFKA-3362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3362: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Update protocol schema and

[jira] [Updated] (KAFKA-2995) in 0.9.0.0 Old Consumer's commitOffsets with specify partition can submit not exists topic and partition to zk

[ https://issues.apache.org/jira/browse/KAFKA-2995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2995: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > in 0.9.0.0 Old Consumer's

[jira] [Updated] (KAFKA-661) Prevent a shutting down broker from re-entering the ISR

[ https://issues.apache.org/jira/browse/KAFKA-661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-661: -- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Prevent a shutting down broker

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

[ https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3554: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Generate actual data with

[jira] [Updated] (KAFKA-2789) Update upgrade system test to catch issue reported in KAFKA-2756

[ https://issues.apache.org/jira/browse/KAFKA-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2789: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Update upgrade system test

[jira] [Commented] (KAFKA-4074) Deleting a topic can make it unavailable even if delete.topic.enable is false

[ https://issues.apache.org/jira/browse/KAFKA-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527613#comment-15527613 ] Jason Gustafson commented on KAFKA-4074: [~omkreddy] Should this be resolved as a duplicate then?

[jira] [Updated] (KAFKA-1019) kafka-preferred-replica-election.sh will fail without clear error message if /brokers/topics/[topic]/partitions does not exist

[ https://issues.apache.org/jira/browse/KAFKA-1019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1019: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 >

[jira] [Updated] (KAFKA-2434) remove roundrobin identical topic constraint in consumer coordinator (old API)

[ https://issues.apache.org/jira/browse/KAFKA-2434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2434: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > remove roundrobin identical

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

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3436: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Speed up controlled

[jira] [Updated] (KAFKA-2526) Console Producer / Consumer's serde config is not working

[ https://issues.apache.org/jira/browse/KAFKA-2526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2526: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Console Producer /

[jira] [Updated] (KAFKA-3515) Migrate org.apache.kafka.connect.json.JsonSerializer / Deser to common package

[ https://issues.apache.org/jira/browse/KAFKA-3515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3515: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Migrate

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

[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2875: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Class path contains multiple

[jira] [Updated] (KAFKA-3437) We don't need sitedocs package for every scala version

[ https://issues.apache.org/jira/browse/KAFKA-3437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3437: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > We don't need sitedocs

[jira] [Updated] (KAFKA-1027) Add documentation for system tests

[ https://issues.apache.org/jira/browse/KAFKA-1027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1027: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add documentation for system

[jira] [Updated] (KAFKA-3368) Add the Message/Record set protocol to the protocol docs

[ https://issues.apache.org/jira/browse/KAFKA-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3368: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add the Message/Record set

[jira] [Updated] (KAFKA-3360) Add a protocol page/section to the official Kafka documentation

[ https://issues.apache.org/jira/browse/KAFKA-3360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3360: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add a protocol page/section

[jira] [Updated] (KAFKA-4102) Is kafka mirror maker in 0.10.X don't support mirror kafka 0.8.X?

[ https://issues.apache.org/jira/browse/KAFKA-4102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4102: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Is kafka mirror maker in

[jira] [Updated] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4084: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > automated leader rebalance

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

[ https://issues.apache.org/jira/browse/KAFKA-3331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3331: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Refactor TopicCommand to

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

[ https://issues.apache.org/jira/browse/KAFKA-1900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1900: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add documentation on usage

[jira] [Updated] (KAFKA-3302) Pass kerberos keytab and principal as part of client config

[ https://issues.apache.org/jira/browse/KAFKA-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3302: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Pass kerberos keytab and

[jira] [Updated] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1194: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > The kafka broker cannot

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

[ https://issues.apache.org/jira/browse/KAFKA-1899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1899: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Update code coverage report

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

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3042: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > updateIsr should stop after

[jira] [Updated] (KAFKA-2522) ConsumerGroupCommand sends all output to STDOUT

[ https://issues.apache.org/jira/browse/KAFKA-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2522: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > ConsumerGroupCommand sends

Build failed in Jenkins: kafka-trunk-jdk7 #1575

See Changes: [ismael] KAFKA-4177; Remove ThrottledReplicationRateLimit from Server Config [ismael] MINOR: Make new consumer default for Mirror Maker -- [...truncated 3830 lines...]

[jira] [Commented] (KAFKA-3697) Clean-up website documentation when it comes to clients

[ https://issues.apache.org/jira/browse/KAFKA-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527429#comment-15527429 ] Ismael Juma commented on KAFKA-3697: Sounds good. > Clean-up website documentation when it comes to

[GitHub] kafka pull request #1914: MINOR: Make new consumer default for Mirror Maker

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

[jira] [Resolved] (KAFKA-3719) Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too narrow

[ https://issues.apache.org/jira/browse/KAFKA-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3719. Resolution: Fixed > Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too >

[jira] [Reopened] (KAFKA-3719) Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too narrow

[ https://issues.apache.org/jira/browse/KAFKA-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reopened KAFKA-3719: > Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too > narrow >

Re: [DISCUSS] KIP-73: Replication Quotas

Thanks Ben, this makes sense to me. As discussed in the PR[1] and the JIRA you filed[2], it probably makes sense to also split the throttle limit replication.quota.throttled.rate into separate leader and follower limits. Ismael [1]

[jira] [Updated] (KAFKA-2903) FileMessageSet's read method maybe has problem when start is not zero

[ https://issues.apache.org/jira/browse/KAFKA-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2903: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > FileMessageSet's read method maybe

[jira] [Updated] (KAFKA-3096) Leader is not set to -1 when it is shutdown if followers are down

[ https://issues.apache.org/jira/browse/KAFKA-3096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3096: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Leader is not set to -1 when it is

[jira] [Updated] (KAFKA-3665) Default ssl.endpoint.identification.algorithm should be https

[ https://issues.apache.org/jira/browse/KAFKA-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3665: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Default

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3173: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Error while moving some partitions

[jira] [Commented] (KAFKA-4144) Allow per stream/table timestamp extractor

[ https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527301#comment-15527301 ] Elias Levy commented on KAFKA-4144: --- Indeed, that is how it is handled today. But it's not a very clean

[jira] [Commented] (KAFKA-4144) Allow per stream/table timestamp extractor

[ https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527237#comment-15527237 ] Guozhang Wang commented on KAFKA-4144: -- With the current TimestampExtractor, the input record is in

[jira] [Updated] (KAFKA-4177) Replication Throttling: Remove ThrottledReplicationRateLimit from Server Config

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

[jira] [Commented] (KAFKA-4177) Replication Throttling: Remove ThrottledReplicationRateLimit from Server Config

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

  1   2   >