Re: [jira] [Commented] (KAFKA-3044) Consumer.poll doesnot return messages when poll interval is less

You can also set fetch.min.bytes, It will be a trade-off between getting the messages as fast as possible, with fetch.min.bytes=0 and the poll at 0. This will result in a lot of empty returns, and a lot of io overhead as compared to getting a lot of massages in one go. If you for example set the fe

[jira] [Commented] (KAFKA-2695) Handle null string/bytes protocol primitives

[ https://issues.apache.org/jira/browse/KAFKA-2695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15073886#comment-15073886 ] Magnus Edenhill commented on KAFKA-2695: This blocks kafka-consumer-groups.sh to d

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

Maciek Makowski created KAFKA-3047: -- Summary: Explicit offset assignment in Log.append can corrupt the log Key: KAFKA-3047 URL: https://issues.apache.org/jira/browse/KAFKA-3047 Project: Kafka

[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 ] Maciek Makowski updated KAFKA-3047: --- Description: {{Log.append()}} has {{assignOffsets}} parameter, which, when set to false, shou

[jira] [Updated] (KAFKA-3045) ZkNodeChangeNotificationListener shouldn't log interrupted exception as error

[ https://issues.apache.org/jira/browse/KAFKA-3045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-3045: --- Labels: security (was: ) > ZkNodeChangeNotificationListener shouldn't log interrupted exception as error > --

[jira] [Created] (KAFKA-3048) incorrect property name ssl.want.client.auth

Jun Rao created KAFKA-3048: -- Summary: incorrect property name ssl.want.client.auth Key: KAFKA-3048 URL: https://issues.apache.org/jira/browse/KAFKA-3048 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-2937) Topics marked for delete in Zookeeper may become undeletable

[ https://issues.apache.org/jira/browse/KAFKA-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15074083#comment-15074083 ] Henri Pihkala commented on KAFKA-2937: -- I ran into this issue as well on 0.9.0.0. I h

[jira] [Commented] (KAFKA-3033) Reassigning partition stuck in progress

[ https://issues.apache.org/jira/browse/KAFKA-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15074182#comment-15074182 ] Leo Xuzhang Lin commented on KAFKA-3033: Updates. After restarting the cluster, th

[jira] [Commented] (KAFKA-3039) Temporary loss of leader resulted in log being completely truncated

[ https://issues.apache.org/jira/browse/KAFKA-3039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15074255#comment-15074255 ] Imran Patel commented on KAFKA-3039: I think it is slightly different - in 2477, the b

[jira] [Commented] (KAFKA-3040) Broker didn't report new data after change in leader

[ https://issues.apache.org/jira/browse/KAFKA-3040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15074270#comment-15074270 ] Imran Patel commented on KAFKA-3040: I don't have the controller logs at hand (I am as

[jira] [Created] (KAFKA-3049) VerifiableProperties does not respect 'default' properties of underlying java.util.Properties instance

Jeffrey Olchovy created KAFKA-3049: -- Summary: VerifiableProperties does not respect 'default' properties of underlying java.util.Properties instance Key: KAFKA-3049 URL: https://issues.apache.org/jira/browse/KAFK

[jira] [Commented] (KAFKA-3049) VerifiableProperties does not respect 'default' properties of underlying java.util.Properties instance

[ https://issues.apache.org/jira/browse/KAFKA-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15074289#comment-15074289 ] Jeffrey Olchovy commented on KAFKA-3049: Can't seem to assign the issue to myself,

[jira] [Updated] (KAFKA-3049) VerifiableProperties does not respect 'default' properties of underlying java.util.Properties instance

[ https://issues.apache.org/jira/browse/KAFKA-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeffrey Olchovy updated KAFKA-3049: --- Affects Version/s: 0.7 0.8.1.1 0.8.2.1

[jira] [Updated] (KAFKA-3049) VerifiableProperties does not respect 'default' properties of underlying java.util.Properties instance

[ https://issues.apache.org/jira/browse/KAFKA-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeffrey Olchovy updated KAFKA-3049: --- Labels: easyfix (was: ) > VerifiableProperties does not respect 'default' properties of under

[jira] [Comment Edited] (KAFKA-3049) VerifiableProperties does not respect 'default' properties of underlying java.util.Properties instance

[ https://issues.apache.org/jira/browse/KAFKA-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15074289#comment-15074289 ] Jeffrey Olchovy edited comment on KAFKA-3049 at 12/29/15 9:20 PM: --

[jira] [Commented] (KAFKA-3049) VerifiableProperties does not respect 'default' properties of underlying java.util.Properties instance

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

[GitHub] kafka pull request: KAFKA-3049: VerifiableProperties does not resp...

GitHub user jeffreyolchovy opened a pull request: https://github.com/apache/kafka/pull/719 KAFKA-3049: VerifiableProperties does not respect 'default' properties of underlying java.util.Properties instance See https://issues.apache.org/jira/browse/KAFKA-3049 for more information.