FIX: In compressed callback, we only call decoder if we have data to send to it.
FIX: In compressed callback, we only call decoder if we have data to send to it.

redBorder/n2kafka,redBorder/n2kafka,redBorder/n2kafka