[ 
https://issues.apache.org/jira/browse/KAFKA-15446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762999#comment-17762999
 ] 

许胜斌 commented on KAFKA-15446:
-----------------------------

now when I restarted node 0, the error is:

[2023-09-08 17:04:55,812] ERROR [ReplicaManager broker=0] Error processing 
append operation on partition device-heartbeat-0 (kafka.server.ReplicaManager)
org.apache.kafka.common.errors.InvalidOffsetException: Attempt to append an 
offset (4301302304) to position 166992 no larger than the last offset appended 
(4303338594) to 
/usr/local/kafka/kafka-logs/device-heartbeat-0/00000000004301302285.index.
[2023-09-08 17:04:55,832] ERROR [ReplicaManager broker=0] Error processing 
append operation on partition msg_for_dispatche-0 (kafka.server.ReplicaManager)
org.apache.kafka.common.errors.InvalidOffsetException: Attempt to append an 
offset (14587689460) to position 192880 no larger than the last offset appended 
(14591245891) to 
/usr/local/kafka/kafka-logs/msg_for_dispatche-0/00000000014587689443.index.
[2023-09-08 17:04:55,838] ERROR [ReplicaManager broker=0] Error processing 
append operation on partition device-heartbeat-0 (kafka.server.ReplicaManager)
org.apache.kafka.common.errors.InvalidOffsetException: Attempt to append an 
offset (4301302302) to position 166992 no larger than the last offset appended 
(4303338594) to 
/usr/local/kafka/kafka-logs/device-heartbeat-0/00000000004301302285.index.
[2023-09-08 17:04:55,851] ERROR [ReplicaManager broker=0] Error processing 
append operation on partition msg_for_dispatche-0 (kafka.server.ReplicaManager)
org.apache.kafka.common.errors.InvalidOffsetException: Attempt to append an 
offset (14587689460) to position 192880 no larger than the last offset appended 
(14591245891) to 
/usr/local/kafka/kafka-logs/msg_for_dispatche-0/00000000014587689443.index.
[2023-09-08 17:04:55,863] ERROR [ReplicaManager broker=0] Error processing 
append operation on partition device-heartbeat-0 (kafka.server.ReplicaManager)
org.apache.kafka.common.errors.InvalidOffsetException: Attempt to append an 
offset (4301302297) to position 166992 no larger than the last offset appended 
(4303338594) to 
/usr/local/kafka/kafka-logs/device-heartbeat-0/00000000004301302285.index.
[2023-09-08 17:04:55,882] ERROR [ReplicaManager broker=0] Error processing 
append operation on partition msg_for_dispatche-0 (kafka.server.ReplicaManager)
org.apache.kafka.common.errors.InvalidOffsetException: Attempt to append an 
offset (14587689460) to position 192880 no larger than the last offset appended 
(14591245891) to 
/usr/local/kafka/kafka-logs/msg_for_dispatche-0/00000000014587689443.index.
[2023-09-08 17:04:55,889] ERROR [ReplicaManager broker=0] Error processing 
append operation on partition device-heartbeat-0 (kafka.server.ReplicaManager)
org.apache.kafka.common.errors.InvalidOffsetException: Attempt to append an 
offset (4301302303) to position 166992 no larger than the last offset appended 
(4303338594) to 
/usr/local/kafka/kafka-logs/device-heartbeat-0/00000000004301302285.index.
[2023-09-08 17:04:55,899] ERROR [ReplicaManager broker=0] Error processing 
append operation on partition msg_for_dispatche-0 (kafka.server.ReplicaManager)
org.apache.kafka.common.errors.InvalidOffsetException: Attempt to append an 
offset (14587689460) to position 192880 no larger than the last offset appended 
(14591245891) to 
/usr/local/kafka/kafka-logs/msg_for_dispatche-0/00000000014587689443.index.

> Upgrading from 2.0 to 2.8, with replica out of sync exceeding 12 hours
> ----------------------------------------------------------------------
>
>                 Key: KAFKA-15446
>                 URL: https://issues.apache.org/jira/browse/KAFKA-15446
>             Project: Kafka
>          Issue Type: Bug
>          Components: replication
>    Affects Versions: 2.8.2
>         Environment: centos7、java8
>            Reporter: 许胜斌
>            Priority: Major
>              Labels: replica
>         Attachments: image-2023-09-08-16-37-12-364.png
>
>
> !image-2023-09-08-16-37-12-364.png!
> There are three brokers in the cluster. When the leader of the partition is 
> node 0, it cannot be synchronized to nodes 1 and 2. This problem has lasted 
> for more than ten hours, and the log.dir of the corresponding partition on 
> nodes 1 and 2 has not been updated for a long time, indicating that data 
> replication has stopped.
> However, when the leader of the partition is node 1 or node 2, it can be 
> synchronized to other nodes.
> the error log is:
> [2023-09-08 16:35:05,238] WARN [ReplicaFetcher replicaId=2, leaderId=0, 
> fetcherId=0] Reset fetch offset for partition msg_for_dispatche-0 from 
> 3636534258 to current leader's start offset 14558984559 
> (kafka.server.ReplicaFetcherThread)
> [2023-09-08 16:35:05,238] INFO The cleaning for partition msg_for_dispatche-0 
> is aborted and paused (kafka.log.LogManager)
> [2023-09-08 16:35:05,238] INFO [Log partition=msg_for_dispatche-0, 
> dir=/usr/local/kafka/kafka-logs] Deleting segments as part of log truncation: 
> LogSegment(baseOffset=3636534258, size=0, lastModifiedTime=1694162105000, 
> largestRecordTimestamp=None) (kafka.log.Log)
> [2023-09-08 16:35:05,241] INFO [Log partition=msg_for_dispatche-0, 
> dir=/usr/local/kafka/kafka-logs] Loading producer state till offset 
> 14558984559 with message format version 2 (kafka.log.Log)
> [2023-09-08 16:35:05,241] INFO Cleaning for partition msg_for_dispatche-0 is 
> resumed (kafka.log.LogManager)



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to