|
46 | 46 | import org.springframework.kafka.KafkaException;
|
47 | 47 | import org.springframework.kafka.core.KafkaOperations;
|
48 | 48 | import org.springframework.kafka.core.ProducerFactory;
|
49 |
| -import org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd; |
50 | 49 | import org.springframework.kafka.support.KafkaHeaders;
|
51 | 50 | import org.springframework.kafka.support.KafkaUtils;
|
52 | 51 | import org.springframework.kafka.support.SendResult;
|
@@ -673,7 +672,7 @@ private void maybeAddOriginalHeaders(Headers kafkaHeaders, ConsumerRecord<?, ?>
|
673 | 672 | }
|
674 | 673 | }
|
675 | 674 |
|
676 |
| - private void maybeAddHeader(Headers kafkaHeaders, String header, byte[] value, HeadersToAdd hta) { |
| 675 | + private void maybeAddHeader(Headers kafkaHeaders, String header, byte[] value, HeaderNames.HeadersToAdd hta) { |
677 | 676 | if (this.whichHeaders.contains(hta)
|
678 | 677 | && (this.appendOriginalHeaders || kafkaHeaders.lastHeader(header) == null)) {
|
679 | 678 | kafkaHeaders.add(header, value);
|
@@ -705,7 +704,7 @@ private void addExceptionInfoHeaders(Headers kafkaHeaders, Exception exception,
|
705 | 704 | HeaderNames.HeadersToAdd.EX_STACKTRACE);
|
706 | 705 | }
|
707 | 706 |
|
708 |
| - private void appendOrReplace(Headers headers, RecordHeader header, HeadersToAdd hta) { |
| 707 | + private void appendOrReplace(Headers headers, RecordHeader header, HeaderNames.HeadersToAdd hta) { |
709 | 708 | if (this.whichHeaders.contains(hta)) {
|
710 | 709 | if (this.stripPreviousExceptionHeaders) {
|
711 | 710 | headers.remove(header.key());
|
|
0 commit comments