diff --git a/cdc/tests/integration_tests/_utils/test_prepare b/cdc/tests/integration_tests/_utils/test_prepare
index 5ff9d73e..5358071e 100644
--- a/cdc/tests/integration_tests/_utils/test_prepare
+++ b/cdc/tests/integration_tests/_utils/test_prepare
@@ -81,8 +81,6 @@ function on_exit() {
 	else
 		echo "Error $STATUS_CODE occurred on $LINE for sink $SINK_TYPE"
 
-		if [ "$SINK_TYPE" == "kafka" ]; then
-			cat "$WORK_DIR"/cdc_kafka_consumer*.log || true
-		fi
+		tail -n +1 "$WORK_DIR"/cdc*.log
 	fi
 }