[
https://issues.apache.org/jira/browse/KAFKA-2009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14357351#comment-14357351
]
Jiangjie Qin commented on KAFKA-2009:
-------------------------------------
Just submitted another small fix patch.
I just realized that I still need to add unacked offset into unacked offsets
list before calling producer.send(), because the callback can also be fired in
producer.send().
The reason I added the unacked offset after calling producer.send() was that
I'm worrying that if something wrong in producer.send() occurs, the offset
would never be removed, but since we exiting on any exception in producer
thread, it might not cause further problem as the entire mirror maker will exit.
> Fix UncheckedOffset.removeOffset synchronization and trace logging issue in
> mirror maker
> ----------------------------------------------------------------------------------------
>
> Key: KAFKA-2009
> URL: https://issues.apache.org/jira/browse/KAFKA-2009
> Project: Kafka
> Issue Type: Bug
> Reporter: Jiangjie Qin
> Assignee: Jiangjie Qin
> Attachments: KAFKA-2009.patch, KAFKA-2009_2015-03-11_11:26:57.patch
>
>
> This ticket is to fix the mirror maker problem on current trunk which is
> introduced in KAFKA-1650.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
