File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed
spring-kafka/src/main/java/org/springframework/kafka/listener Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change 1616
1717package org .springframework .kafka .listener ;
1818
19+ import java .lang .reflect .Array ;
1920import java .nio .ByteBuffer ;
2021import java .time .Duration ;
2122import java .util .AbstractMap .SimpleEntry ;
@@ -2238,11 +2239,14 @@ protected void doInTransactionWithoutResult(TransactionStatus status) {
22382239
22392240 private List <ConsumerRecord <K , V >> createRecordList (final ConsumerRecords <K , V > records ) {
22402241 Iterator <ConsumerRecord <K , V >> iterator = records .iterator ();
2241- List <ConsumerRecord <K , V >> list = new LinkedList <>();
2242+ @ SuppressWarnings ("unchecked" ) ConsumerRecord <K , V >[] recordsArray =
2243+ (ConsumerRecord <K , V >[]) Array .newInstance (ConsumerRecord .class , records .count ());
2244+ int index = 0 ;
22422245 while (iterator .hasNext ()) {
2243- list .add (iterator .next ());
2246+ recordsArray [index ] = iterator .next ();
2247+ index += 1 ;
22442248 }
2245- return list ;
2249+ return Arrays . asList ( recordsArray ) ;
22462250 }
22472251
22482252 /**
You can’t perform that action at this time.
0 commit comments