Fix: check if decoded slice is empty before decoding kafka records

[racevedoo]

Problem:

• Memory usage increased a lot when elasticsearch insertion failed

Cause:

• Decoded records buffer was being appended every time with duplicate records

Solution:

• Check if buffer is empty(no records decoded) before actually decoding kafka messages