[jira] [Updated] (KAFKA-2993) compression-rate-avg always returns 0 even with compression.type being set

[ https://issues.apache.org/jira/browse/KAFKA-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TAO XIAO updated KAFKA-2993: Affects Version/s: 0.9.0.0 > compression-rate-avg always returns 0 even with compression.type being set > --

[GitHub] kafka pull request: KAFKA-2993: Calculate compression rate at clos...

GitHub user xiaotao183 opened a pull request: https://github.com/apache/kafka/pull/784 KAFKA-2993: Calculate compression rate at close() call Buffer is rewound before the compression rate metric is updated which results in 0 compress rate. The fix is to include a new compressRate fi

[jira] [Updated] (KAFKA-2993) compression-rate-avg always returns 0 even with compression.type being set

[ https://issues.apache.org/jira/browse/KAFKA-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TAO XIAO updated KAFKA-2993: Status: Patch Available (was: Open) > compression-rate-avg always returns 0 even with compression.type bein

[jira] [Commented] (KAFKA-2993) compression-rate-avg always returns 0 even with compression.type being set

[ https://issues.apache.org/jira/browse/KAFKA-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15103660#comment-15103660 ] ASF GitHub Bot commented on KAFKA-2993: --- GitHub user xiaotao183 opened a pull reques

[jira] [Updated] (KAFKA-2993) compression-rate-avg always returns 0 even with compression.type being set

[ https://issues.apache.org/jira/browse/KAFKA-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TAO XIAO updated KAFKA-2993: Component/s: producer > compression-rate-avg always returns 0 even with compression.type being set > --

[jira] [Created] (KAFKA-3113) Kafka simple consumer inconsistent result

Goutam Chowdhury created KAFKA-3113: --- Summary: Kafka simple consumer inconsistent result Key: KAFKA-3113 URL: https://issues.apache.org/jira/browse/KAFKA-3113 Project: Kafka Issue Type: Bug

[GitHub] kafka pull request: KAFKA-2944: fix NullPointerException in KafkaC...

Github user ZoneMayor closed the pull request at: https://github.com/apache/kafka/pull/723 --- 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 en

[GitHub] kafka pull request: KAFKA-2944: fix NullPointerException in KafkaC...

GitHub user ZoneMayor reopened a pull request: https://github.com/apache/kafka/pull/723 KAFKA-2944: fix NullPointerException in KafkaConfigStorage Lost of "config messages" can affect the logic of KafkaConfigStorage; Call readToEnd after sending each message to KafkaBasedLog to e

[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&focusedCommentId=15103738#comment-15103738 ] ASF GitHub Bot commented on KAFKA-2944: --- GitHub user ZoneMayor reopened a pull reque

[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&focusedCommentId=15103737#comment-15103737 ] ASF GitHub Bot commented on KAFKA-2944: --- Github user ZoneMayor closed the pull reque

[jira] [Created] (KAFKA-3114) can't create as many partitions as brokers exists

Lukas Schmitt created KAFKA-3114: Summary: can't create as many partitions as brokers exists Key: KAFKA-3114 URL: https://issues.apache.org/jira/browse/KAFKA-3114 Project: Kafka Issue Type: B

[GitHub] kafka pull request: KAFKA-2944: fix NullPointerException in KafkaC...

GitHub user ZoneMayor reopened a pull request: https://github.com/apache/kafka/pull/723 KAFKA-2944: fix NullPointerException in KafkaConfigStorage Lost of "config messages" can affect the logic of KafkaConfigStorage; Call readToEnd after sending each message to KafkaBasedLog to e

[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&focusedCommentId=15103773#comment-15103773 ] ASF GitHub Bot commented on KAFKA-2944: --- GitHub user ZoneMayor reopened a pull reque

[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&focusedCommentId=15103772#comment-15103772 ] ASF GitHub Bot commented on KAFKA-2944: --- Github user ZoneMayor closed the pull reque

[GitHub] kafka pull request: KAFKA-2944: fix NullPointerException in KafkaC...

Github user ZoneMayor closed the pull request at: https://github.com/apache/kafka/pull/723 --- 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 en

[jira] [Created] (KAFKA-3115) Remove locking in metrics package

Jay Kreps created KAFKA-3115: Summary: Remove locking in metrics package Key: KAFKA-3115 URL: https://issues.apache.org/jira/browse/KAFKA-3115 Project: Kafka Issue Type: Improvement R

[GitHub] kafka pull request: KAFKA-2993: Calculate compression rate at clos...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/784 --- 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 enabl

[jira] [Commented] (KAFKA-2993) compression-rate-avg always returns 0 even with compression.type being set

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

[jira] [Updated] (KAFKA-2993) compression-rate-avg always returns 0 even with compression.type being set

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

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

See Changes: [wangguoz] KAFKA-2993: Calculate compression rate at close() call -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubunt

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

See Changes: [wangguoz] KAFKA-2993: Calculate compression rate at close() call -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubunt

[jira] [Commented] (KAFKA-3085) BrokerChangeListener computes inconsistent live/dead broker list

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

[GitHub] kafka pull request: KAFKA-3085: BrokerChangeListener computes inco...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/756 --- 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 enabl

[jira] [Updated] (KAFKA-3085) BrokerChangeListener computes inconsistent live/dead broker list

[ https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-3085: --- Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was: Patch Available) Issue reso

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

See Changes: [junrao] KAFKA-3085; BrokerChangeListener computes inconsistent live/dead broker -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H1

Jenkins build is back to normal : kafka-trunk-jdk8 #292

See

[jira] [Commented] (KAFKA-2066) Replace FetchRequest / FetchResponse with their org.apache.kafka.common.requests equivalents

[ https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15104883#comment-15104883 ] David Jacot commented on KAFKA-2066: In the current implementation, FetchResponse cont