-
Notifications
You must be signed in to change notification settings - Fork 1.7k
Closed
Description
@DltHandler
void handler(Message<?> msg,
@Header(KafkaHeaders.ORIGINAL_OFFSET) long offset,
@Header(KafkaHeaders.EXCEPTION_FQCN) String descException,
@Header(KafkaHeaders.EXCEPTION_STACKTRACE) String stacktrace,
@Header(KafkaHeaders.EXCEPTION_MESSAGE) String errorMessage) {
System.out.println(msg);
System.out.println(offset);
System.out.println(descException);
System.out.println(stacktrace);
System.out.println(errorMessage);
}
offset is always 0.
Work around:
@DltHandler
void handler(Message<?> msg,
@Header(KafkaHeaders.ORIGINAL_OFFSET) byte[] offset,
@Header(KafkaHeaders.EXCEPTION_FQCN) String descException,
@Header(KafkaHeaders.EXCEPTION_STACKTRACE) String stacktrace,
@Header(KafkaHeaders.EXCEPTION_MESSAGE) String errorMessage) {
System.out.println(msg);
System.out.println(ByteBuffer.wrap(offset).getLong());
System.out.println(descException);
System.out.println(stacktrace);
System.out.println(errorMessage);
}