You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/17 14:35:00 UTC
[jira] [Created] (KAFKA-16156) System test failing on endOffsets with negative timestamps
Lianet Magrans created KAFKA-16156:
--------------------------------------
Summary: System test failing on endOffsets with negative timestamps
Key: KAFKA-16156
URL: https://issues.apache.org/jira/browse/KAFKA-16156
Project: Kafka
Issue Type: Sub-task
Components: clients
Reporter: Lianet Magrans
TransactionalMessageCopier run with 3.7 new consumer fails with "Invalid negative timestamp".
Trace:
[2024-01-15 07:42:33,933] ERROR Shutting down after unexpected error in event loop (org.apache.kafka.tools.TransactionalMessageCopier)
org.apache.kafka.common.KafkaException: java.lang.IllegalArgumentException: Invalid negative timestamp
at org.apache.kafka.clients.consumer.internals.ConsumerUtils.maybeWrapAsKafkaException(ConsumerUtils.java:234)
at org.apache.kafka.clients.consumer.internals.ConsumerUtils.getResult(ConsumerUtils.java:212)
at org.apache.kafka.clients.consumer.internals.events.CompletableApplicationEvent.get(CompletableApplicationEvent.java:44)
at org.apache.kafka.clients.consumer.internals.events.ApplicationEventHandler.addAndGet(ApplicationEventHandler.java:113)
at org.apache.kafka.clients.consumer.internals.AsyncKafkaConsumer.beginningOrEndOffset(AsyncKafkaConsumer.java:1134)
at org.apache.kafka.clients.consumer.internals.AsyncKafkaConsumer.endOffsets(AsyncKafkaConsumer.java:1113)
at org.apache.kafka.clients.consumer.internals.AsyncKafkaConsumer.endOffsets(AsyncKafkaConsumer.java:1108)
at org.apache.kafka.clients.consumer.KafkaConsumer.endOffsets(KafkaConsumer.java:1651)
at org.apache.kafka.tools.TransactionalMessageCopier.messagesRemaining(TransactionalMessageCopier.java:246)
at org.apache.kafka.tools.TransactionalMessageCopier.runEventLoop(TransactionalMessageCopier.java:342)
at org.apache.kafka.tools.TransactionalMessageCopier.main(TransactionalMessageCopier.java:292)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)