Skip to content

Commit 506ba35

Browse files
Gunju-Koartembilan
authored andcommitted
Fix typo in invokeRecordListenerInTx method name
1 parent 1bef976 commit 506ba35

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -991,7 +991,7 @@ private RuntimeException doInvokeBatchListener(final ConsumerRecords<K, V> recor
991991

992992
private void invokeRecordListener(final ConsumerRecords<K, V> records) {
993993
if (this.transactionTemplate != null) {
994-
innvokeRecordListenerInTx(records);
994+
invokeRecordListenerInTx(records);
995995
}
996996
else {
997997
doInvokeWithRecords(records);
@@ -1003,7 +1003,7 @@ private void invokeRecordListener(final ConsumerRecords<K, V> records) {
10031003
* @param records the records.
10041004
*/
10051005
@SuppressWarnings({ "rawtypes" })
1006-
private void innvokeRecordListenerInTx(final ConsumerRecords<K, V> records) {
1006+
private void invokeRecordListenerInTx(final ConsumerRecords<K, V> records) {
10071007
Iterator<ConsumerRecord<K, V>> iterator = records.iterator();
10081008
while (iterator.hasNext()) {
10091009
final ConsumerRecord<K, V> record = iterator.next();

0 commit comments

Comments
 (0)