[
https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-802:
--------------------------------
Attachment: kafka-802.patch
Two changes -
1. Changed the maybeFlush() call from Log.append() to take in number of
appended messages. On the leader, this will be the uncompressed message count,
but on the follower, this will still be the compressed message count since we
don't recompress data on the follower. I think this is fine.
2. Changed the default of log.flush.interval.messages to 10000 instead of 500.
With replication, a very low default for this config doesn't make sense
> Flush message interval is based on compressed message count
> -----------------------------------------------------------
>
> Key: KAFKA-802
> URL: https://issues.apache.org/jira/browse/KAFKA-802
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 0.8
> Reporter: Jun Rao
> Priority: Blocker
> Attachments: kafka-802.patch
>
>
> In Log.append(), we use compressed message count to determine whether to
> flush the log or not. We should use uncompressed message count instead.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
