[
https://issues.apache.org/jira/browse/KAFKA-3157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-3157:
----------------------------
Description:
Mirror maker doesn't commit messages with new consumer enabled when messages
are sent to source within the time range that is smaller than commit interval
and no more messages are sent afterwards.
The steps to reproduce:
1. Start mirror maker.
2. The default commit interval is 1 min. Send message for less than 1 min for
example 10 seconds.
3. Don't send more messages.
4. Check committed offset with group command. The lag remains unchanged for
ever even though the messages have been sent to destination.
was:
Mirror maker doesn't commit messages with new consumer enabled when messages
are sent to source within the time range that is smaller than commit interval
and no more messages are sent beyond.
The steps to reproduce:
1. Start mirror maker.
2. The default commit interval is 1 min. Send message for less than 1 min for
example 10 seconds.
3. Don't send more messages.
4. Check committed offset with group command. The lag remains unchanged for
ever even though the messages have been sent to destination.
> Mirror maker doesn't commit offset with new consumer when there is no more
> messages
> -----------------------------------------------------------------------------------
>
> Key: KAFKA-3157
> URL: https://issues.apache.org/jira/browse/KAFKA-3157
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.9.0.0
> Reporter: TAO XIAO
> Assignee: TAO XIAO
>
> Mirror maker doesn't commit messages with new consumer enabled when messages
> are sent to source within the time range that is smaller than commit interval
> and no more messages are sent afterwards.
> The steps to reproduce:
> 1. Start mirror maker.
> 2. The default commit interval is 1 min. Send message for less than 1 min for
> example 10 seconds.
> 3. Don't send more messages.
> 4. Check committed offset with group command. The lag remains unchanged for
> ever even though the messages have been sent to destination.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
